public class ClientProducerCreditsImpl extends Object implements ClientProducerCredits
Constructor and Description |
---|
ClientProducerCreditsImpl(ClientSessionInternal session,
SimpleString address,
int windowSize) |
Modifier and Type | Method and Description |
---|---|
void |
acquireCredits(int credits) |
void |
close() |
int |
decrementRefCount() |
int |
getBalance() |
void |
incrementRefCount() |
void |
init(SessionContext sessionContext) |
boolean |
isBlocked() |
void |
receiveCredits(int credits) |
void |
receiveFailCredits(int credits) |
void |
releaseOutstanding() |
void |
reset() |
public ClientProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)
public void init(SessionContext sessionContext)
init
in interface ClientProducerCredits
public void acquireCredits(int credits) throws ActiveMQException
acquireCredits
in interface ClientProducerCredits
ActiveMQException
public boolean isBlocked()
isBlocked
in interface ClientProducerCredits
public int getBalance()
public void receiveCredits(int credits)
receiveCredits
in interface ClientProducerCredits
public void receiveFailCredits(int credits)
receiveFailCredits
in interface ClientProducerCredits
public void reset()
reset
in interface ClientProducerCredits
public void close()
close
in interface ClientProducerCredits
public void incrementRefCount()
incrementRefCount
in interface ClientProducerCredits
public int decrementRefCount()
decrementRefCount
in interface ClientProducerCredits
public void releaseOutstanding()
releaseOutstanding
in interface ClientProducerCredits
Copyright © 2017 JBoss by Red Hat. All rights reserved.