public class ProducerBrokerExchange extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ProducerBrokerExchange.FlowControlInfo |
Constructor and Description |
---|
ProducerBrokerExchange() |
Modifier and Type | Method and Description |
---|---|
void |
blockingOnFlowControl(boolean blockingOnFlowControl) |
boolean |
canDispatch(Message messageSend)
Enforce duplicate suppression using info from persistence adapter
|
ProducerBrokerExchange |
copy() |
ConnectionContext |
getConnectionContext() |
int |
getPercentageBlocked() |
ProducerState |
getProducerState() |
Region |
getRegion() |
Destination |
getRegionDestination() |
long |
getTotalTimeBlocked() |
void |
incrementSend() |
void |
incrementTimeBlocked(Destination destination,
long timeBlocked) |
boolean |
isBlockedForFlowControl() |
boolean |
isMutable() |
void |
resetFlowControl() |
void |
setConnectionContext(ConnectionContext connectionContext) |
void |
setLastStoredSequenceId(long l) |
void |
setMutable(boolean mutable) |
void |
setProducerState(ProducerState producerState) |
void |
setRegion(Region region) |
void |
setRegionDestination(Destination regionDestination) |
public ProducerBrokerExchange()
public ProducerBrokerExchange copy()
public ConnectionContext getConnectionContext()
public void setConnectionContext(ConnectionContext connectionContext)
connectionContext
- the connectionContext to setpublic boolean isMutable()
public void setMutable(boolean mutable)
mutable
- the mutable to setpublic Destination getRegionDestination()
public void setRegionDestination(Destination regionDestination)
regionDestination
- the regionDestination to setpublic ProducerState getProducerState()
public void setProducerState(ProducerState producerState)
producerState
- the producerState to setpublic boolean canDispatch(Message messageSend)
public void setLastStoredSequenceId(long l)
public void incrementSend()
public void blockingOnFlowControl(boolean blockingOnFlowControl)
public void incrementTimeBlocked(Destination destination, long timeBlocked)
public boolean isBlockedForFlowControl()
public void resetFlowControl()
public long getTotalTimeBlocked()
public int getPercentageBlocked()
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.