org.apache.activemq.broker
public class ConnectionContext extends java.lang.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 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 java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> getTransactions()
public void setTransactions(java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> transactions)
public boolean isInTransaction()
public java.lang.String getClientId()
public void setClientId(java.lang.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 java.lang.String getUserName()
protected void setUserName(java.lang.String userName)
public MessageEvaluationContext getMessageEvaluationContext()
public java.lang.Object getLongTermStoreContext()
public void setLongTermStoreContext(java.lang.Object longTermStoreContext)
public boolean isProducerFlowControl()
public void setProducerFlowControl(boolean disableProducerFlowControl)
public boolean isAllowedToConsume(MessageReference n) throws java.io.IOException
java.io.IOException
public boolean isNetworkConnection()
public void setNetworkConnection(boolean networkConnection)
public java.util.concurrent.atomic.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-2014. All Rights Reserved.