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() |
boolean |
isBlocked() |
void |
receiveCredits(int credits) |
void |
releaseOutstanding() |
void |
reset() |
public ClientProducerCreditsImpl(ClientSessionInternal session, SimpleString address, int windowSize)
public void init()
init
in interface ClientProducerCredits
public void acquireCredits(int credits) throws InterruptedException
acquireCredits
in interface ClientProducerCredits
InterruptedException
public boolean isBlocked()
isBlocked
in interface ClientProducerCredits
public int getBalance()
public void receiveCredits(int credits)
receiveCredits
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 © 2012 JBoss by Red Hat. All Rights Reserved.