public class ConnectionFactory<T extends ConnectionFactory<T>> extends Object
Constructor and Description |
---|
ConnectionFactory(String key) |
Modifier and Type | Method and Description |
---|---|
void |
addPropertyChangeListener(PropertyChangeListener listener)
Adds a property change listener
|
Boolean |
autoGroup()
Whether or not message grouping is automatically used
|
T |
autoGroup(Boolean value)
Whether or not message grouping is automatically used
|
Boolean |
blockOnAcknowledge()
True to set block on acknowledge.
|
T |
blockOnAcknowledge(Boolean value)
True to set block on acknowledge.
|
Boolean |
blockOnDurableSend()
True to set block on durable send.
|
T |
blockOnDurableSend(Boolean value)
True to set block on durable send.
|
Boolean |
blockOnNonDurableSend()
True to set block on non durable send.
|
T |
blockOnNonDurableSend(Boolean value)
True to set block on non durable send.
|
Boolean |
cacheLargeMessageClient()
True to cache large messages.
|
T |
cacheLargeMessageClient(Boolean value)
True to cache large messages.
|
Long |
callFailoverTimeout()
The timeout to use when fail over is in process (in ms).
|
T |
callFailoverTimeout(Long value)
The timeout to use when fail over is in process (in ms).
|
Long |
callTimeout()
The call time out.
|
T |
callTimeout(Long value)
The call time out.
|
Long |
clientFailureCheckPeriod()
The client failure check period.
|
T |
clientFailureCheckPeriod(Long value)
The client failure check period.
|
String |
clientId()
The client id.
|
T |
clientId(String value)
The client id.
|
Boolean |
compressLargeMessages()
Whether large messages should be compressed.
|
T |
compressLargeMessages(Boolean value)
Whether large messages should be compressed.
|
Integer |
confirmationWindowSize()
The confirmation window size.
|
T |
confirmationWindowSize(Integer value)
The confirmation window size.
|
String |
connectionLoadBalancingPolicyClassName()
Name of a class implementing a client-side load balancing policy that a
client can use to load balance sessions across different nodes in a
cluster.
|
T |
connectionLoadBalancingPolicyClassName(String value)
Name of a class implementing a client-side load balancing policy that a
client can use to load balance sessions across different nodes in a
cluster.
|
Long |
connectionTtl()
The connection ttl.
|
T |
connectionTtl(Long value)
The connection ttl.
|
T |
connector(String value)
Defines the connectors.
|
List<String> |
connectors()
Defines the connectors.
|
T |
connectors(List<String> value)
Defines the connectors.
|
T |
connectors(String... args)
Defines the connectors.
|
Integer |
consumerMaxRate()
The consumer max rate.
|
T |
consumerMaxRate(Integer value)
The consumer max rate.
|
Integer |
consumerWindowSize()
The consumer window size.
|
T |
consumerWindowSize(Integer value)
The consumer window size.
|
List<String> |
deserializationBlackList()
A list of class names (separated by whitespaces) that are black-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationBlackList(List<String> value)
A list of class names (separated by whitespaces) that are black-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationBlackList(String... args)
A list of class names (separated by whitespaces) that are black-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationBlackList(String value)
A list of class names (separated by whitespaces) that are black-listed to
be used in serialization of JMS ObjectMessage.
|
List<String> |
deserializationWhiteList()
A list of class names (separated by whitespaces) that are white-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationWhiteList(List<String> value)
A list of class names (separated by whitespaces) that are white-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationWhiteList(String... args)
A list of class names (separated by whitespaces) that are white-listed to
be used in serialization of JMS ObjectMessage.
|
T |
deserializationWhiteList(String value)
A list of class names (separated by whitespaces) that are white-listed to
be used in serialization of JMS ObjectMessage.
|
String |
discoveryGroup()
The discovery group name.
|
T |
discoveryGroup(String value)
The discovery group name.
|
Integer |
dupsOkBatchSize()
The dups ok batch size.
|
T |
dupsOkBatchSize(Integer value)
The dups ok batch size.
|
List<String> |
entries()
The jndi names the connection factory should be bound to.
|
T |
entries(List<String> value)
The jndi names the connection factory should be bound to.
|
T |
entries(String... args)
The jndi names the connection factory should be bound to.
|
T |
entry(String value)
The jndi names the connection factory should be bound to.
|
FactoryType |
factoryType()
The type of connection factory.
|
T |
factoryType(FactoryType value)
The type of connection factory.
|
Boolean |
failoverOnInitialConnection()
True to fail over on initial connection.
|
T |
failoverOnInitialConnection(Boolean value)
True to fail over on initial connection.
|
String |
getKey() |
String |
groupId()
The group id.
|
T |
groupId(String value)
The group id.
|
Boolean |
ha()
Whether the connection factory supports High Availability.
|
T |
ha(Boolean value)
Whether the connection factory supports High Availability.
|
Integer |
initialMessagePacketSize()
The initial size of messages created through this factory.
|
T |
initialMessagePacketSize(Integer value)
The initial size of messages created through this factory.
|
Long |
maxRetryInterval()
The max retry interval.
|
T |
maxRetryInterval(Long value)
The max retry interval.
|
Integer |
minLargeMessageSize()
The min large message size.
|
T |
minLargeMessageSize(Integer value)
The min large message size.
|
Boolean |
preAcknowledge()
True to pre-acknowledge.
|
T |
preAcknowledge(Boolean value)
True to pre-acknowledge.
|
Integer |
producerMaxRate()
The producer max rate.
|
T |
producerMaxRate(Integer value)
The producer max rate.
|
Integer |
producerWindowSize()
The producer window size.
|
T |
producerWindowSize(Integer value)
The producer window size.
|
String |
protocolManagerFactory()
The protocol manager factory used by this connection factory (it must
implement org.apache.activemq.artemis.spi.core.remoting.
|
T |
protocolManagerFactory(String value)
The protocol manager factory used by this connection factory (it must
implement org.apache.activemq.artemis.spi.core.remoting.
|
Integer |
reconnectAttempts()
The reconnect attempts.
|
T |
reconnectAttempts(Integer value)
The reconnect attempts.
|
void |
removePropertyChangeListener(PropertyChangeListener listener)
Removes a property change listener
|
Long |
retryInterval()
The retry interval.
|
T |
retryInterval(Long value)
The retry interval.
|
Double |
retryIntervalMultiplier()
The retry interval multiplier.
|
T |
retryIntervalMultiplier(Double value)
The retry interval multiplier.
|
Integer |
scheduledThreadPoolMaxSize()
The scheduled thread pool max size.
|
T |
scheduledThreadPoolMaxSize(Integer value)
The scheduled thread pool max size.
|
Integer |
threadPoolMaxSize()
The thread pool max size.
|
T |
threadPoolMaxSize(Integer value)
The thread pool max size.
|
Integer |
transactionBatchSize()
The transaction batch size.
|
T |
transactionBatchSize(Integer value)
The transaction batch size.
|
Boolean |
useGlobalPools()
True to use global pools.
|
T |
useGlobalPools(Boolean value)
True to use global pools.
|
public ConnectionFactory(String key)
public String getKey()
public void addPropertyChangeListener(PropertyChangeListener listener)
public void removePropertyChangeListener(PropertyChangeListener listener)
public Boolean autoGroup()
public Boolean blockOnAcknowledge()
public Boolean blockOnDurableSend()
public Boolean blockOnNonDurableSend()
public T blockOnNonDurableSend(Boolean value)
public Boolean cacheLargeMessageClient()
public T cacheLargeMessageClient(Boolean value)
public Long callFailoverTimeout()
public T callFailoverTimeout(Long value)
public Long callTimeout()
public Long clientFailureCheckPeriod()
public T clientFailureCheckPeriod(Long value)
public String clientId()
public Boolean compressLargeMessages()
public T compressLargeMessages(Boolean value)
public Integer confirmationWindowSize()
public String connectionLoadBalancingPolicyClassName()
public T connectionLoadBalancingPolicyClassName(String value)
public Long connectionTtl()
public List<String> connectors()
public T connectors(List<String> value)
public T connector(String value)
public T connectors(String... args)
public Integer consumerMaxRate()
public Integer consumerWindowSize()
public List<String> deserializationBlackList()
public T deserializationBlackList(List<String> value)
public T deserializationBlackList(String value)
public T deserializationBlackList(String... args)
public List<String> deserializationWhiteList()
public T deserializationWhiteList(List<String> value)
public T deserializationWhiteList(String value)
public T deserializationWhiteList(String... args)
public String discoveryGroup()
public Integer dupsOkBatchSize()
public T entries(List<String> value)
public FactoryType factoryType()
public T factoryType(FactoryType value)
public Boolean failoverOnInitialConnection()
public T failoverOnInitialConnection(Boolean value)
public String groupId()
public Boolean ha()
public Integer initialMessagePacketSize()
public T initialMessagePacketSize(Integer value)
public Long maxRetryInterval()
public Integer minLargeMessageSize()
public Boolean preAcknowledge()
public Integer producerMaxRate()
public Integer producerWindowSize()
public String protocolManagerFactory()
public T protocolManagerFactory(String value)
public Integer reconnectAttempts()
public Long retryInterval()
public Double retryIntervalMultiplier()
public T retryIntervalMultiplier(Double value)
public Integer scheduledThreadPoolMaxSize()
public T scheduledThreadPoolMaxSize(Integer value)
public Integer threadPoolMaxSize()
public Integer transactionBatchSize()
public Boolean useGlobalPools()
Copyright © 2019 JBoss by Red Hat. All rights reserved.