public class AmqpConnectionProperties extends Object
Constructor and Description |
---|
AmqpConnectionProperties(JmsConnectionInfo connectionInfo)
Creates a new instance of this class with default values read from the
given JmsConnectionInfo object.
|
Modifier and Type | Method and Description |
---|---|
String |
getQueuePrefix() |
String |
getTopicPrefix() |
void |
initialize(org.apache.qpid.proton.amqp.Symbol[] capabilities,
Map<org.apache.qpid.proton.amqp.Symbol,Object> properties)
Configure the properties using values provided from the remote peer.
|
boolean |
isAnonymousRelaySupported() |
boolean |
isConnectionOpenFailed()
Returns true if the remote connection marked the open response as being in
a failed state which implies that a close follows.
|
protected void |
processCapabilities(org.apache.qpid.proton.amqp.Symbol[] capabilities) |
protected void |
processProperties(Map<org.apache.qpid.proton.amqp.Symbol,Object> properties) |
void |
setAnonymousRelaySupported(boolean anonymousRelaySupported)
Sets if the connection supports sending to an anonymous relay link.
|
void |
setConnectionOpenFailed(boolean connectionOpenFailed)
Sets the state of the connection open failed flag.
|
void |
setQueuePrefix(String queuePrefix)
Sets the prefix value used to decorate Queue address values.
|
void |
setTopicPrefix(String topicPrefix)
Sets the prefix value used to decorate Topic address values.
|
public AmqpConnectionProperties(JmsConnectionInfo connectionInfo)
connectionInfo
- the JmsConnectionInfo object used to populate defaults.public void initialize(org.apache.qpid.proton.amqp.Symbol[] capabilities, Map<org.apache.qpid.proton.amqp.Symbol,Object> properties)
capabilities
- the capabilities offered by the remote connection.properties
- the properties offered by the remote connection.protected void processCapabilities(org.apache.qpid.proton.amqp.Symbol[] capabilities)
protected void processProperties(Map<org.apache.qpid.proton.amqp.Symbol,Object> properties)
public boolean isAnonymousRelaySupported()
public void setAnonymousRelaySupported(boolean anonymousRelaySupported)
anonymousRelaySupported
- true if anonymous relay link is supported.public String getQueuePrefix()
public void setQueuePrefix(String queuePrefix)
queuePrefix
- the current queue address prefix.public String getTopicPrefix()
public void setTopicPrefix(String topicPrefix)
topicPrefix
- the current topic address prefix.public boolean isConnectionOpenFailed()
public void setConnectionOpenFailed(boolean connectionOpenFailed)
connectionOpenFailed
- the connectionOpenFailed value to use for these properties.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.