public ConnectionContext() 
{
    	this.messageEvaluationContext = new MessageEvaluationContext();
}

 public ConnectionContext(MessageEvaluationContext messageEvaluationContext) 
{
    	this.messageEvaluationContext=messageEvaluationContext;
}

 public ConnectionContext(ConnectionInfo info) 
{
    	this();
        setClientId(info.getClientId());
        setUserName(info.getUserName());
        setConnectionId(info.getConnectionId());
}

 public ConnectionContext copy() 
{
        ConnectionContext rc = new ConnectionContext(this.messageEvaluationContext);
        rc.connection = this.connection;
        rc.connector = this.connector;
        rc.broker = this.broker;
        rc.inRecoveryMode = this.inRecoveryMode;
        rc.transaction = this.transaction;
        rc.transactions = this.transactions;
        rc.securityContext = this.securityContext;
        rc.connectionId = this.connectionId;
        rc.clientId = this.clientId;
        rc.userName = this.userName;
        rc.haAware = this.haAware;
        rc.wireFormatInfo = this.wireFormatInfo;
        rc.longTermStoreContext = this.longTermStoreContext;
        rc.producerFlowControl = this.producerFlowControl;
        rc.messageAuthorizationPolicy = this.messageAuthorizationPolicy;
        rc.networkConnection = this.networkConnection;
        rc.faultTolerant = this.faultTolerant;
        rc.stopping.set(this.stopping.get());
        rc.dontSendReponse = this.dontSendReponse;
        rc.clientMaster = this.clientMaster;
        return rc;
}

 public Broker getBroker() 
{
        return broker;
}

 public String getClientId() 
{
        return clientId;
}

 public Connection getConnection() 
{
        return connection;
}

 public ConnectionId getConnectionId() 
{
        return connectionId;
}

 public Connector getConnector() 
{
        return connector;
}

 public Object getLongTermStoreContext() 
{
        return longTermStoreContext;
}

 public MessageAuthorizationPolicy getMessageAuthorizationPolicy() 
{
        return messageAuthorizationPolicy;
}

 public MessageEvaluationContext getMessageEvaluationContext() 
{
        return messageEvaluationContext;
}

 public SecurityContext getSecurityContext() 
{
        return securityContext;
}

 public AtomicBoolean getStopping() 
{
        return stopping;
}

 public Transaction getTransaction() 
{
        return transaction;
}

 public ConcurrentHashMap<TransactionId, Transaction> getTransactions() 
{
        return transactions;
}

 public String getUserName() 
{
        return userName;
}

 public WireFormatInfo getWireFormatInfo() 
{
        return wireFormatInfo;
}

 public boolean isAllowedToConsume(MessageReference n) throws IOException 
{
        if (messageAuthorizationPolicy != null) {
            return messageAuthorizationPolicy.isAllowedToConsume(this, n.getMessage());
        }
        return true;
}

 public boolean isClientMaster() 
{
        return this.clientMaster;
}

 public boolean isDontSendReponse() 
{
        return dontSendReponse;
}

 public boolean isFaultTolerant() 
{
        return faultTolerant;
}

 public boolean isHaAware() 
{
        return haAware;
}

 public boolean isInRecoveryMode() 
{
        return inRecoveryMode;
}

 public boolean isInTransaction() 
{
        return transaction != null;
}

 public synchronized boolean isNetworkConnection() 
{
        return networkConnection;
}

 public boolean isProducerFlowControl() 
{
        return producerFlowControl;
}

 public boolean isSlave() 
{
        return (this.broker != null && this.broker.getBrokerService().isSlave()) || !this.clientMaster;
}

 public  void setBroker(Broker broker) 
{
        this.broker = broker;
}

 public  void setClientId(String clientId) 
{
        this.clientId = clientId;
}

 public  void setClientMaster(boolean clientMaster) 
{
        this.clientMaster = clientMaster;
}

 public  void setConnection(Connection connection) 
{
        this.connection = connection;
}

 public  void setConnectionId(ConnectionId connectionId) 
{
        this.connectionId = connectionId;
}

 public  void setConnector(Connector connector) 
{
        this.connector = connector;
}

 public  void setDontSendReponse(boolean b) 
{
        this.dontSendReponse = b;
}

 public  void setFaultTolerant(boolean faultTolerant) 
{
        this.faultTolerant = faultTolerant;
}

 public  void setHaAware(boolean haAware) 
{
        this.haAware = haAware;
}

 public  void setInRecoveryMode(boolean inRecoveryMode) 
{
        this.inRecoveryMode = inRecoveryMode;
}

 public  void setLongTermStoreContext(Object longTermStoreContext) 
{
        this.longTermStoreContext = longTermStoreContext;
}

 public  void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy) 
{
        this.messageAuthorizationPolicy = messageAuthorizationPolicy;
}

Sets the policy used to decide if the current connection is authorized to consume a given message

 public synchronized  void setNetworkConnection(boolean networkConnection) 
{
        this.networkConnection = networkConnection;
}

 public  void setProducerFlowControl(boolean disableProducerFlowControl) 
{
        this.producerFlowControl = disableProducerFlowControl;
}

 public  void setSecurityContext(SecurityContext subject) 
{
        this.securityContext = subject;
        if (subject != null) {
            setUserName(subject.getUserName());
        } else {
            setUserName(null);
        }
}

 public  void setTransaction(Transaction transaction) 
{
        this.transaction = transaction;
}

 public  void setTransactions(ConcurrentHashMap<TransactionId, Transaction> transactions) 
{
        this.transactions = transactions;
}

 protected  void setUserName(String userName) 
{
        this.userName = userName;
}

 public  void setWireFormatInfo(WireFormatInfo wireFormatInfo) 
{
        this.wireFormatInfo = wireFormatInfo;
}