public class ConnectionContext extends Object
Constructor and Description |
---|
ConnectionContext() |
ConnectionContext(ConnectionInfo info) |
ConnectionContext(MessageEvaluationContext messageEvaluationContext) |
public ConnectionContext()
public ConnectionContext(MessageEvaluationContext messageEvaluationContext)
public ConnectionContext(ConnectionInfo info)
public ConnectionContext copy()
public SecurityContext getSecurityContext()
public void setSecurityContext(SecurityContext subject)
public Broker getBroker()
public void setBroker(Broker broker)
broker
- being usedpublic Connection getConnection()
public void setConnection(Connection connection)
connection
- being usedpublic Transaction getTransaction()
public void setTransaction(Transaction transaction)
transaction
- being used.public Connector getConnector()
public void setConnector(Connector connector)
connector
- being used.public MessageAuthorizationPolicy getMessageAuthorizationPolicy()
public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
public boolean isInRecoveryMode()
public void setInRecoveryMode(boolean inRecoveryMode)
public ConcurrentHashMap<TransactionId,Transaction> getTransactions()
public void setTransactions(ConcurrentHashMap<TransactionId,Transaction> transactions)
public boolean isInTransaction()
public String getClientId()
public void setClientId(String clientId)
public boolean isReconnect()
public void setReconnect(boolean reconnect)
public WireFormatInfo getWireFormatInfo()
public void setWireFormatInfo(WireFormatInfo wireFormatInfo)
public ConnectionId getConnectionId()
public void setConnectionId(ConnectionId connectionId)
public String getUserName()
protected void setUserName(String userName)
public MessageEvaluationContext getMessageEvaluationContext()
public Object getLongTermStoreContext()
public void setLongTermStoreContext(Object longTermStoreContext)
public boolean isProducerFlowControl()
public void setProducerFlowControl(boolean disableProducerFlowControl)
public boolean isAllowedToConsume(MessageReference n) throws IOException
IOException
public boolean isNetworkConnection()
public void setNetworkConnection(boolean networkConnection)
public AtomicBoolean getStopping()
public void setDontSendReponse(boolean b)
public boolean isDontSendReponse()
public boolean isSlave()
public boolean isClientMaster()
public void setClientMaster(boolean clientMaster)
clientMaster
- the clientMaster to setpublic boolean isFaultTolerant()
public void setFaultTolerant(boolean faultTolerant)
public void setConnectionState(ConnectionState connectionState)
public ConnectionState getConnectionState()
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.