- changeMessagePriority(long, int) - Method in interface org.hornetq.api.core.management.QueueControl
-
Changes the message's priority corresponding to the specified message ID to the specified priority.
- changeMessagesPriority(String, int) - Method in interface org.hornetq.api.core.management.QueueControl
-
Changes the priority for all the message corresponding to the specified filter to the specified priority.
- checkCompletion() - Method in interface org.hornetq.api.core.client.ClientMessage
-
This can be optionally used to verify if the entire message has been received.
- checkDataReceived() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
returns true if any data has been received since the last time this method was called.
- checkFlushBatchBuffer() - Method in interface org.hornetq.spi.core.remoting.Connection
-
Called periodically to flush any data in the batch buffer
- cleanup() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Opposed to close, will call cleanup only on every created session and children objects.
- ClientConsumer - Interface in org.hornetq.api.core.client
-
A ClientConsumer receives messages from HornetQ queues.
- ClientMessage - Interface in org.hornetq.api.core.client
-
A ClientMessage represents a message sent and/or received by HornetQ.
- ClientProducer - Interface in org.hornetq.api.core.client
-
A ClientProducer is used to send messages to a specific address.
- ClientRequestor - Class in org.hornetq.api.core.client
-
The ClientRequestor class helps making requests.
- ClientRequestor(ClientSession, SimpleString) - Constructor for class org.hornetq.api.core.client.ClientRequestor
-
Constructor for the ClientRequestor.
- ClientRequestor(ClientSession, String) - Constructor for class org.hornetq.api.core.client.ClientRequestor
-
- ClientSession - Interface in org.hornetq.api.core.client
-
A ClientSession is a single-thread object required for producing and consuming messages.
- ClientSession.BindingQuery - Interface in org.hornetq.api.core.client
-
Information returned by a binding query
- ClientSession.QueueQuery - Interface in org.hornetq.api.core.client
-
Information returned by a queue query
- ClientSessionFactory - Interface in org.hornetq.api.core.client
-
A ClientSessionFactory is the entry point to create and configure HornetQ resources to produce and consume messages.
- close(boolean) - Method in interface org.hornetq.api.core.BroadcastEndpoint
-
Close the endpoint.
- close() - Method in interface org.hornetq.api.core.client.ClientConsumer
-
Closes the consumer.
- close() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Closes the ClientProducer.
- close() - Method in class org.hornetq.api.core.client.ClientRequestor
-
Closes the ClientRequestor and its session.
- close() - Method in interface org.hornetq.api.core.client.ClientSession
-
Closes the session.
- close() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Closes this factory and any session created by it.
- close() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Closes this factory and release all its resources
- close() - Method in interface org.hornetq.spi.core.remoting.Connection
-
Closes the connection.
- close() - Method in interface org.hornetq.spi.core.remoting.Connector
-
closes the connector
- closeConnectionsForAddress(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Closes all the connections of clients connected to this server which matches the specified IP address.
- ClusterConnectionControl - Interface in org.hornetq.api.core.management
-
A ClusterConnectionControl is used to manage a cluster connection.
- ClusterTopologyListener - Interface in org.hornetq.api.core.client
-
A cluster topology listener.
- commit() - Method in interface org.hornetq.api.core.client.ClientSession
-
Commits the current transaction.
- commitPreparedTransaction(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Heuristically commits a prepared transaction.
- configuration - Variable in class org.hornetq.spi.core.remoting.AbstractConnector
-
- connection - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry
-
- Connection - Interface in org.hornetq.spi.core.remoting
-
The connection used by a channel to write data to.
- connectionCreated(HornetQComponent, Connection, String) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener
-
This method is used both by client connector creation and server connection creation through
acceptors.
- connectionDestroyed(Object) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener
-
Called when a connection is destroyed.
- ConnectionEntry - Class in org.hornetq.spi.core.protocol
-
A ConnectionEntry
- ConnectionEntry(RemotingConnection, Executor, long, long) - Constructor for class org.hornetq.spi.core.protocol.ConnectionEntry
-
- connectionException(Object, HornetQException) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener
-
Called when an error occurs on the connection.
- connectionExecutor - Variable in class org.hornetq.spi.core.protocol.ConnectionEntry
-
- ConnectionLifeCycleListener - Interface in org.hornetq.spi.core.remoting
-
A ConnectionLifeCycleListener is called by the remoting implementation to notify of connection events.
- ConnectionLoadBalancingPolicy - Interface in org.hornetq.api.core.client.loadbalance
-
A ConnectionLoadBalancingPolicy defines a policy to load balance between connections.
- connectionReadyForWrites(Object, boolean) - Method in interface org.hornetq.spi.core.remoting.ConnectionLifeCycleListener
-
- Connector - Interface in org.hornetq.spi.core.remoting
-
A Connector is used by the client for creating and controlling a connection.
- ConnectorFactory - Interface in org.hornetq.spi.core.remoting
-
A ConnectorFactory is used by the client for creating connectors.
- containsProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns true
if this message contains a property with the given key, false
else.
- containsProperty(String) - Method in interface org.hornetq.api.core.Message
-
- CORE_ACCEPTOR - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_ADDRESS - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_BRIDGE - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_BROADCAST_GROUP - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_CLUSTER_CONNECTION - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_DISCOVERY_GROUP - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_DIVERT - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_QUEUE - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- CORE_SERVER - Static variable in class org.hornetq.api.core.management.ResourceNames
-
- countMessages(String) - Method in interface org.hornetq.api.core.management.QueueControl
-
Counts the number of messages in this queue matching the specified filter.
- create(String) - Static method in class org.hornetq.api.core.management.ObjectNameBuilder
-
- createBridge(String, String, String, String, String, long, double, int, boolean, int, long, String, boolean, boolean, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- createBroadcastEndpoint() - Method in interface org.hornetq.api.core.BroadcastEndpointFactory
-
- createBroadcastEndpointFactory() - Method in interface org.hornetq.api.core.BroadcastEndpointFactoryConfiguration
-
- createBroadcastEndpointFactory() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration
-
- createBroadcastEndpointFactory() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration
-
- createBuffer(int) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
creates a new HornetQBuffer of the specified size.
- createBuffer(int) - Method in interface org.hornetq.spi.core.remoting.Connection
-
Create a new HornetQBuffer of the given size.
- createConnection() - Method in interface org.hornetq.spi.core.remoting.Connector
-
Create and return a connection from this connector.
- createConnector(Map<String, Object>, BufferHandler, ConnectionLifeCycleListener, Executor, Executor, ScheduledExecutorService) - Method in interface org.hornetq.spi.core.remoting.ConnectorFactory
-
creates a new instance of a connector.
- createConsumer(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume message from the queue with the given name.
- createConsumer(String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume messages from the queue with the given name.
- createConsumer(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
- createConsumer(String, String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume messages matching the filter from the queue with the given name.
- createConsumer(SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
- createConsumer(String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages from the queue with the given name.
- createConsumer(String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
- createConsumer(SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
- createConsumer(SimpleString, SimpleString, int, int, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
- createConsumer(String, String, int, int, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientConsumer to consume or browse messages matching the filter from the queue with
the given name.
- createDivert(String, String, String, String, boolean, String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- createMessage(boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientMessage.
- createMessage(byte, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientMessage.
- createMessage(byte, boolean, long, long, byte) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a ClientMessage.
- createProducer() - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a producer with no default address.
- createProducer(SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a producer which sends messages to the given address
- createProducer(String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a producer which sends messages to the given address
- createProducer(SimpleString, int) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a producer which sends messages to the given address
- createQueue(SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporary queue.
- createQueue(String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporary queue.
- createQueue(String, String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporary queue non-durable queue.
- createQueue(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporary queue non-durable queue.
- createQueue(SimpleString, SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporary queue.
- createQueue(String, String, String, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a non-temporaryqueue.
- createQueue(String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Create a durable queue.
- createQueue(String, String, String, boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Create a queue.
- createQueue(String, String, boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Create a queue.
- createServerLocator(boolean, TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically
as the cluster topology changes, and no HA backup information is propagated to the client
- createServerLocator(boolean, DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client The UDP address and port are used to listen for
live servers in the cluster
- createServerLocatorWithHA(TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which will receive cluster topology updates from the cluster as servers
leave or join and new backups are appointed or removed.
- createServerLocatorWithHA(DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which will receive cluster topology updates from the cluster as servers
leave or join and new backups are appointed or removed.
- createServerLocatorWithoutHA(TransportConfiguration...) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which creates session factories using a static list of transportConfigurations, the ServerLocator is not updated automatically
as the cluster topology changes, and no HA backup information is propagated to the client
- createServerLocatorWithoutHA(DiscoveryGroupConfiguration) - Static method in class org.hornetq.api.core.client.HornetQClient
-
Create a ServerLocator which creates session factories from a set of live servers, no HA
backup information is propagated to the client
- createSession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a non-transacted session.
- createSession(boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a session.
- createSession(boolean, boolean, int) - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a session.
- createSession(boolean, boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a session.
- createSession(boolean, boolean, boolean, boolean) - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a session.
- createSession(String, String, boolean, boolean, boolean, boolean, int) - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates an authenticated session.
- createSessionFactory() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Creates a ClientSessionFactory using whatever load balancing policy is in force
- createSessionFactory(String) - Method in interface org.hornetq.api.core.client.ServerLocator
-
- createSessionFactory(TransportConfiguration) - Method in interface org.hornetq.api.core.client.ServerLocator
-
- createSessionFactory(TransportConfiguration, int, boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
- createSharedQueue(SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a transient queue.
- createSharedQueue(SimpleString, SimpleString, SimpleString, boolean) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a transient queue.
- createTemporaryQueue(SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a temporary queue.
- createTemporaryQueue(String, String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a temporary queue.
- createTemporaryQueue(SimpleString, SimpleString, SimpleString) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a temporary queue with a filter.
- createTemporaryQueue(String, String, String) - Method in interface org.hornetq.api.core.client.ClientSession
-
Creates a temporary queue with a filter.
- createTransactedSession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a transacted session.
- createXASession() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Creates a session with XA transaction semantics.
- getAcceptorObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by AcceptorControl.
- getAckBatchSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the acknowledgments batch size.
- getAddress() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Returns the address where messages will be sent.
- getAddress() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns the address that the queue is bound to.
- getAddress() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the managed address.
- getAddress() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the address used by this cluster connection.
- getAddress() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns the origin address used by this divert.
- getAddress() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the address this queue is bound to.
- getAddress() - Method in interface org.hornetq.api.core.Message
-
Returns the address this message is sent to.
- getAddressFullMessagePolicy() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getAddressNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the addresses created on this server.
- getAddressObjectName(SimpleString) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by AddressControl.
- getAddressSettingsAsJSON(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
returns the address settings as a JSON string
- getAddressSize() - Method in interface org.hornetq.api.core.management.AddressControl
-
- getAllowableProperties() - Method in interface org.hornetq.spi.core.remoting.ConnectorFactory
-
Returns the allowable properties for this connector.
- getBackup() - Method in interface org.hornetq.api.core.client.TopologyMember
-
Returns the TransportConfiguration relative to the backup server if any.
- getBackupGroupName() - Method in interface org.hornetq.api.core.client.TopologyMember
-
Returns the backup-group-name
of the live server and backup servers associated with
Topology entry.
- getBindingNames() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the names of all bindings (both queues and diverts) bound to this address
- getBindingsDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the file system directory used to store bindings.
- getBodyBuffer() - Method in interface org.hornetq.api.core.Message
-
Returns the message body as a HornetQBuffer
- getBodyBufferCopy() - Method in interface org.hornetq.api.core.Message
-
Returns a copy of the message body as a HornetQBuffer.
- getBodySize() - Method in interface org.hornetq.api.core.client.ClientMessage
-
Returns the size (in bytes) of this message's body
- getBooleanProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Boolean.
- getBooleanProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getBridgeNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- getBridgeObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by BridgeControl.
- getBroadcastEndpointFactoryConfiguration() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- getBroadcastGroupObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by BroadcastGroupControl.
- getBroadcastPeriod() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- getBroadcastPeriod() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the period used by this broadcast group.
- getByteProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Byte.
- getByteProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getBytesProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a byte[].
- getBytesProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getCallFailoverTimeout() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the blocking calls failover timeout when the client is awaiting failover,
this is over and above the normal call timeout.
- getCallTimeout() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the blocking calls timeout.
- getClientFailureCheckPeriod() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the period used to check if a client has failed to receive pings from the server.
- getClusterConnectionObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by ClusterConnectionControl.
- getConfirmationWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the size for the confirmation window of clients using this factory.
- getConnection() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
Returns the code connection used by this session factory.
- getConnectionCount() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the number of connections connected to this server.
- getConnectionFactoryObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by ConnectionFactoryControl.
- getConnectionLoadBalancingPolicyClassName() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the class name of the connection load balancing policy.
- getConnectionTTL() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the connection time-to-live.
- getConnectionTTLOverride() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the connection time to live.
- getConnectorConfig() - Method in interface org.hornetq.spi.core.remoting.Connection
-
- getConnectorInfos() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- getConnectorPairs() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the pairs of live-backup connectors that are broadcasted by this broadcast group.
- getConnectorPairsAsJSON() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the pairs of live-backup connectors that are broadcasted by this broadcast group
using JSON serialization.
- getConnectors() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the connectors configured for this server.
- getConnectorsAsJSON() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the connectors configured for this server using JSON serialization.
- getConsumerCount() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns the number of consumers attached to the queue.
- getConsumerCount() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the number of consumers consuming messages from this queue.
- getConsumerMaxRate() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum rate of message consumption for consumers created through this factory.
- getConsumerWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the window size for flow control of the consumers created through this factory.
- getCounters() - Method in class org.hornetq.api.core.management.DayCounterInfo
-
Returns a 24-length array corresponding to the number of messages added to the queue
for the given hour of the day.
- getCreationTime() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
- getDate() - Method in class org.hornetq.api.core.management.DayCounterInfo
-
Returns the date of the counter.
- getDeadLetterAddress() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getDeadLetterAddress() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the dead-letter address associated to this queue.
- getDefaultBindingsDirectory() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the directory to store the persisted bindings to
- getDefaultBridgeConnectSameNode() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Upon reconnection this configures the number of time the same node on the topology will be retried before reseting the server locator and using the initial connectors
- getDefaultBridgeReconnectAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
maximum number of retry attempts, -1 means 'no limits'
- getDefaultBroadcastPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
period in milliseconds between consecutive broadcasts
- getDefaultBroadcastRefreshTimeout() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Period the discovery group waits after receiving the last broadcast from a particular server before removing that servers connector pair entry from its list.
- getDefaultClientFailureCheckPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultClusterConnectionTtl() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how long to keep a connection alive in the absence of any data arriving from the client
- getDefaultClusterFailureCheckPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
The period (in milliseconds) used to check if the cluster connection has failed to receive pings from another server
- getDefaultClusterMaxHops() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
maximum number of hops cluster topology is propagated
- getDefaultClusterMaxRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Maximum value for retry-interval
- getDefaultClusterNotificationAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how many times this cluster connection will notify the cluster of its existence right after joining the cluster
- getDefaultClusterNotificationInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how often the cluster connection will notify the cluster of its existence right after joining the cluster
- getDefaultClusterPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Cluster password.
- getDefaultClusterReconnectAttempts() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
How many attempts should be made to reconnect after failure
- getDefaultClusterRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
period (in ms) between successive retries
- getDefaultClusterRetryIntervalMultiplier() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
multiplier to apply to the retry-interval
- getDefaultClusterUser() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Cluster username.
- getDefaultConnectionTtl() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how long to keep a connection alive in the absence of any data arriving from the client.
- getDefaultConnectionTtlOverride() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
if set, this will override how long (in ms) to keep a connection alive without receiving a ping.
- getDefaultFailbackDelay() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
delay to wait before fail-back occurs on (live's) restart
- getDefaultFileDeployerScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultHornetQPrincipal() - Method in interface org.hornetq.spi.core.remoting.Connection
-
- getDefaultIdCacheSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the size of the cache for pre-creating message ID's
- getDefaultJmxDomain() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the JMX domain used to registered HornetQ MBeans in the MBeanServer
- getDefaultJournalBufferSizeAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalBufferSizeNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalBufferTimeoutAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalBufferTimeoutNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalCompactMinFiles() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
The minimal number of data files before we can start compacting
- getDefaultJournalCompactPercentage() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
The percentage of live data on which we consider compacting the journal
- getDefaultJournalDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the directory to store the journal files in
- getDefaultJournalFileSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the size (in bytes) of each journal file
- getDefaultJournalMaxIoAio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalMaxIoNio() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getDefaultJournalMinFiles() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how many journal files to pre-create
- getDefaultJournalPerfBlastPages() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
XXX Only meant to be used by project developers
- getDefaultLargeMessagesDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the directory to store large messages
- getDefaultManagementAddress() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the name of the management address to send management messages to.
- getDefaultManagementNotificationAddress() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the name of the address that consumers bind to receive management notifications
- getDefaultMaxConcurrentPageIo() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
The max number of concurrent reads allowed on paging
- getDefaultMaxRetryInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Limit to the retry-interval growth (due to retry-interval-multiplier)
- getDefaultMaxSavedReplicatedJournalsSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
This specifies how many times a replicated backup server can restart after moving its files on start.
- getDefaultMemoryMeasureInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
frequency to sample JVM memory in ms (or -1 to disable memory sampling)
- getDefaultMemoryWarningThreshold() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Percentage of available memory which will trigger a warning log
- getDefaultMessageCounterMaxDayHistory() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how many days to keep message counter history
- getDefaultMessageCounterSamplePeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the sample period (in ms) to use for message counters
- getDefaultMessageExpiryScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how often (in ms) to scan for expired messages
- getDefaultMessageExpiryThreadPriority() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the priority of the thread expiring messages
- getDefaultPagingDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
the directory to store paged messages in
- getDefaultRetryIntervalMultiplier() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
multiplier to apply to successive retry intervals
- getDefaultScheduledThreadPoolMaxSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Maximum number of threads to use for the scheduled thread pool
- getDefaultSecurityInvalidationInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how long (in ms) to wait before invalidating the security cache
- getDefaultServerDumpInterval() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Interval to log server specific information (e.g.
- getDefaultThreadPoolMaxSize() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Maximum number of threads to use for the thread pool.
- getDefaultTransactionTimeout() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how long (in ms) before a transaction can be removed from the resource manager after create time
- getDefaultTransactionTimeoutScanPeriod() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
how often (in ms) to scan for timeout transactions
- getDeliveringCount() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the number of messages that this queue is currently delivering to its consumers.
- getDeliveryCount() - Method in interface org.hornetq.api.core.client.ClientMessage
-
Returns the number of times this message was delivered.
- getDiscoveryGroupConfiguration() - Method in interface org.hornetq.api.core.client.ServerLocator
-
The discovery group configuration
- getDiscoveryGroupName() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the name of the discovery group used by this bridge.
- getDiscoveryGroupName() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the name of the discovery group used by this cluster connection.
- getDiscoveryGroupObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by DiscoveryGroupControl.
- getDiscoveryInitialWaitTimeout() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- getDivertNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- getDivertObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by DivertControl.
- getDoubleProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Double.
- getDoubleProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getEncodeSize() - Method in interface org.hornetq.api.core.Message
-
Returns the size of the encoded message.
- getEndpointFactoryConfiguration() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- getExpiration() - Method in interface org.hornetq.api.core.Message
-
Returns the expiration time of this message.
- getExpiryAddress() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getExpiryAddress() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the expiry address associated to this queue.
- getFactoryClassName() - Method in interface org.hornetq.api.core.management.AcceptorControl
-
Returns the class name of the AcceptorFactory implementation
used by this acceptor.
- getFactoryClassName() - Method in class org.hornetq.api.core.TransportConfiguration
-
Returns the class name of ConnectorFactory being used by this TransportConfiguration
- getFailureListeners() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
return all the failure listeners
- getFilter() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns the filter used by this divert.
- getFilter() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the filter associated to this queue.
- getFilterString() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns the queue's filter string (or null
if the queue has no filter).
- getFilterString() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the filter string associated to this bridge.
- getFirstMessageAsJSON() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the first message on the queue as JSON
- getFloatProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Float.
- getFloatProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getForwardingAddress() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the address this bridge will forward messages to.
- getForwardingAddress() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns the forwarding address used by this divert.
- getGroupAddress() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper
-
- getGroupAddress() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration
-
- getGroupAddress() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the address this broadcast group is broadcasting to.
- getGroupAddress() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration
-
- getGroupID() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the group ID that will be eventually set on each message for the property
Message.HDR_GROUP_ID
.
- getGroupPort() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper
-
- getGroupPort() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration
-
- getGroupPort() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the port this broadcast group is broadcasting to.
- getGroupPort() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration
-
- getHornetQServerObjectName() - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
- getID() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns this queue ID.
- getID() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
- getID() - Method in interface org.hornetq.spi.core.remoting.Connection
-
returns the unique id of this wire.
- getIDCacheSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the size of the cache for pre-creating message IDs.
- getIncomingInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the list of interceptors used by this server for incoming messages.
- getInitialConnectAttempts() - Method in interface org.hornetq.api.core.client.ServerLocator
-
- getInitialMessagePacketSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the initial size of messages created through this factory.
- getInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- getIntProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as an Integer.
- getIntProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getJMSQueueObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by JMSQueueControl.
- getJMSServerObjectName() - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by JMSServerControl.
- getJMSTopicObjectName(String) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by TopicControl.
- getJournalBufferSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the size of the internal buffer on the journal.
- getJournalBufferTimeout() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the timeout (in nanoseconds) used to flush internal buffers on the journal.
- getJournalCompactMinFiles() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the minimal number of journal files before compacting.
- getJournalCompactPercentage() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Return the percentage of live data before compacting the journal.
- getJournalDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the file system directory used to store journal log.
- getJournalFileSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the size (in bytes) of each journal files.
- getJournalMaxIO() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the maximum number of write requests that can be in the AIO queue at any given time.
- getJournalMinFiles() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the number of journal files to pre-create.
- getJournalType() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the type of journal used by this server (either NIO
or ASYNCIO
).
- getLargeMessagesDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the file system directory used to store large messages.
- getLastException() - Method in interface org.hornetq.api.core.client.ClientConsumer
-
Returns the last exception thrown by a call to this consumer's MessageHandler.
- getLive() - Method in interface org.hornetq.api.core.client.TopologyMember
-
- getLocalBindAddress() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper
-
- getLocalBindAddress() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration
-
- getLocalBindAddress() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration
-
- getLocalBindPort() - Method in interface org.hornetq.api.core.DiscoveryGroupConfigurationCompatibilityHelper
-
- getLocalBindPort() - Method in class org.hornetq.api.core.JGroupsBroadcastGroupConfiguration
-
- getLocalBindPort() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the local port this broadcast group is bound to.
- getLocalBindPort() - Method in class org.hornetq.api.core.UDPBroadcastGroupConfiguration
-
- getLongProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Long.
- getLongProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getManagementAddress() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the management address of this server.
- getManagementNotificationAddress() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the management notification address of this server.
- getMaxDeliveryAttempts() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getMaxHops() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the maximum number of hops used by this cluster connection.
- getMaxRate() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Returns the maximum rate at which a ClientProducer can send messages per second.
- getMaxRedeliveryDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getMaxRetryInterval() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum retry interval (in the case a retry interval multiplier has been specified).
- getMaxSizeBytes() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getMessageCount() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns the number of messages in the queue.
- getMessageCount() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the number of messages currently in this queue.
- getMessageCounterMaxDayCount() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the maximum number of days kept in memory for message counter.
- getMessageCounterSamplePeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the sample period (in milliseconds) to take message counter snapshot.
- getMessageExpiryScanPeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the frequency (in milliseconds) to scan messages to detect which messages
have expired.
- getMessageExpiryThreadPriority() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the priority of the thread used to scan message expiration.
- getMessageHandler() - Method in interface org.hornetq.api.core.client.ClientConsumer
-
Returns the MessageHandler associated to this consumer.
- getMessageID() - Method in interface org.hornetq.api.core.Message
-
Returns the messageID.
- getMessagesAdded() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the number of messages added to this queue since it was created.
- getMinLargeMessageSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the large message size threshold.
- getName() - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- getName() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- getName() - Method in interface org.hornetq.api.core.management.AcceptorControl
-
Returns the name of the acceptor
- getName() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the name of this bridge
- getName() - Method in interface org.hornetq.api.core.management.BroadcastGroupControl
-
Returns the configuration name of this broadcast group.
- getName() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the configuration name of this cluster connection.
- getName() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the name of this queue.
- getName() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns the name of the role.
- getName() - Method in class org.hornetq.api.core.TransportConfiguration
-
Returns the name of this TransportConfiguration.
- getNodeId() - Method in interface org.hornetq.api.core.client.TopologyMember
-
Returns the nodeId of the server.
- getNodeID() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the node ID used by this cluster connection.
- getNodes() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns a map of the nodes connected to this cluster connection.
- getNumberOfBytesPerPage() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the number of bytes used by each page for this address.
- getNumberOfMessages() - Method in interface org.hornetq.api.core.management.AddressControl
-
- getNumberOfPages() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the number of pages used by this address.
- getObjectProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key
- getObjectProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getOutgoingInterceptorClassNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the list of interceptors used by this server for outgoing messages.
- getPageCacheMaxSize() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getPageSizeBytes() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getPagingDirectory() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the file system directory used to store paging files.
- getParameters() - Method in interface org.hornetq.api.core.management.AcceptorControl
-
Returns the parameters used to configure this acceptor
- getParams() - Method in class org.hornetq.api.core.TransportConfiguration
-
Returns any parameters set for this TransportConfiguration
- getPriority() - Method in interface org.hornetq.api.core.Message
-
Returns the message priority.
- getProducerMaxRate() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum rate of message production for producers created through this factory.
- getProducerWindowSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the window size for flow control of the producers created through this factory.
- getPropertyNames() - Method in interface org.hornetq.api.core.Message
-
Returns all the names of the properties for this message.
- getPropMaskPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getPropPasswordCodec() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
- getQueueName() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the name of the queue this bridge is consuming messages from.
- getQueueNames() - Method in interface org.hornetq.api.core.client.ClientSession.BindingQuery
-
Returns the names of the queues bound to the binding.
- getQueueNames() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the names of the queues bound to this address.
- getQueueNames() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the names of the queues created on this server.
- getQueueObjectName(SimpleString, SimpleString) - Method in class org.hornetq.api.core.management.ObjectNameBuilder
-
Returns the ObjectName used by QueueControl.
- getReconnectAttempts() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum number of attempts to retry connection in case of failure.
- getReconnectAttempts() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the number of reconnection attempts used by this bridge.
- getRedeliveryDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getRedeliveryMultiplier() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getRedistributionDelay() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- getRefreshTimeout() - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- getRemoteAddress() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
returns a string representation of the remote address of this connection
- getRemoteAddress() - Method in interface org.hornetq.spi.core.remoting.Connection
-
Returns a string representation of the remote address this connection is connected to.
- getResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper
-
Returns the result of an operation invocation or an attribute value.
- getResults(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper
-
Returns the result of an operation invocation or an attribute value.
- getRetryInterval() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the time to retry connections created by this factory after failure.
- getRetryInterval() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the retry interval used by this bridge.
- getRetryInterval() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the connection retry interval used by this cluster connection.
- getRetryIntervalMultiplier() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the multiplier to apply to successive retry intervals.
- getRetryIntervalMultiplier() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns the retry interval multiplier used by this bridge.
- getRoles() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the roles (name and permissions) associated to this address.
- getRoles(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- getRolesAsJSON() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns the roles (name and permissions) associated to this address
using JSON serialization.
- getRolesAsJSON(String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
- getRoutingName() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns the routing name of this divert.
- getScheduledCount() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns the number of scheduled messages in this queue.
- getScheduledThreadPoolMaxSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum size of the scheduled thread pool.
- getScheduledThreadPoolMaxSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the maximum number of threads in the scheduled thread pool.
- getSecurityInvalidationInterval() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the interval time (in milliseconds) to invalidate security credentials.
- getServerLocator() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
- getShortProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a Short.
- getShortProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getSimpleStringProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a SimpleString.
- getSimpleStringProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getStaticConnectors() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns any list of static connectors used by this bridge
- getStaticConnectors() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the list of static connectors
- getStaticConnectorsAsJSON() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Returns the list of static connectors as JSON
- getStaticTransportConfigurations() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns an array of TransportConfigurations representing the static list of live servers used
when creating this object
- getStringProperty(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Returns the property corresponding to the specified key as a String.
- getStringProperty(String) - Method in interface org.hornetq.api.core.Message
-
- getThreadPoolMaxSize() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the maximum size of the thread pool.
- getThreadPoolMaxSize() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the maximum number of threads in the thread pool.
- getTimestamp() - Method in interface org.hornetq.api.core.Message
-
Returns the message timestamp.
- getTopology() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Exposes the Topology used by this ServerLocator.
- getTopology() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Return the Topology that this Cluster Connection knows about
- getTransactionTimeout() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the timeout (in milliseconds) after which transactions is removed
from the resource manager after it was created.
- getTransactionTimeoutScanPeriod() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns the frequency (in milliseconds) to scan transactions to detect which transactions
have timed out.
- getTransformerClassName() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Return the name of the org.hornetq.core.server.cluster.Transformer implementation associated to this bridge.
- getTransformerClassName() - Method in interface org.hornetq.api.core.management.DivertControl
-
Return the name of the org.hornetq.core.server.cluster.Transformer implementation associated to this bridge.
- getTransportConnection() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
return the underlying Connection.
- getType() - Method in interface org.hornetq.api.core.Message
-
Returns this message type.
- getUniqueEventID() - Method in interface org.hornetq.api.core.client.TopologyMember
-
- getUniqueName() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns the cluster-wide unique name of this divert.
- getUserID() - Method in interface org.hornetq.api.core.Message
-
Returns the userID - this is an optional user specified UUID that can be set to identify the message
and will be passed around with the message
- getVersion() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns the server's incrementingVersion.
- getVersion() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns this server's version.
- getXAResource() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns the XAResource associated to the session.
- individualAcknowledge() - Method in interface org.hornetq.api.core.client.ClientMessage
-
Acknowledges reception of a single message.
- INITIAL_CONNECT_ATTEMPTS - Static variable in class org.hornetq.api.core.client.HornetQClient
-
- intercept(Packet, RemotingConnection) - Method in interface org.hornetq.api.core.Interceptor
-
Intercepts a packet which is received before it is sent to the channel
- Interceptor - Interface in org.hornetq.api.core
-
This is class is a simple way to intercepting calls on HornetQ client and servers.
- intValue() - Method in enum org.hornetq.api.core.management.NotificationType
-
- isAsyncConnectionExecutionEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether code coming from connection is executed asynchronously or not.
- isAttributesResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper
-
Returns whether the JMS message corresponds to the result of a management attribute value.
- isAutoCommitAcks() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns whether the session will automatically commit its transaction every time a message is acknowledged
by a ClientConsumer created by this session, false
else
- isAutoCommitSends() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns whether the session will automatically commit its transaction every time a message is sent
by a ClientProducer created by this session, false
else
- isAutoGroup() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether producers created through this factory will automatically
assign a group ID to the messages they sent.
- isBackup() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns true
if this server is a backup, false
if it is a live server.
- isBlockOnAcknowledge() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns whether the ClientConsumer created by the session will block when they acknowledge a message.
- isBlockOnAcknowledge() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether consumers created through this factory will block while
sending message acknowledgments or do it asynchronously.
- isBlockOnDurableSend() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Returns whether the producer will block when sending durable messages.
- isBlockOnDurableSend() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether producers created through this factory will block while sending durable messages or do it asynchronously.
- isBlockOnNonDurableSend() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Returns whether the producer will block when sending non-durable messages.
- isBlockOnNonDurableSend() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether producers created through this factory will block while sending non-durable messages or do it asynchronously.
- isCacheLargeMessagesClient() - Method in interface org.hornetq.api.core.client.ServerLocator
-
When true
, consumers created through this factory will create temporary files to
cache large messages.
- isClient() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
- isClosed() - Method in interface org.hornetq.api.core.client.ClientConsumer
-
Returns whether the consumer is closed or not.
- isClosed() - Method in interface org.hornetq.api.core.client.ClientProducer
-
Returns whether the producer is closed or not.
- isClosed() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns whether the session is closed or not.
- isClosed() - Method in interface org.hornetq.api.core.client.ClientSessionFactory
-
- isClosed() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns true if close was already called
- isClustered() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether this server is clustered.
- isCompressLargeMessage() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Whether to compress large messages.
- isConsume() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can consume messages from queues bound to the address.
- isCreateBindingsDir() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether the bindings directory is created on this server startup.
- isCreateDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can create durable queues bound to the address.
- isCreateJournalDir() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether the journal directory is created on this server startup.
- isCreateNonDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can create non-durable queues bound to the address.
- isDefaultAllowAutoFailback() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Whether a server will automatically stop when a another places a request to take over its place.
- isDefaultAsyncConnectionExecutionEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Should incoming packets on the server be handed off to a thread from the thread pool for processing or should they be handled on the remoting thread?
- isDefaultBackup() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
whether this server is a backup server
- isDefaultBridgeDuplicateDetection() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
should duplicate detection headers be inserted in forwarded messages?
- isDefaultCheckForLiveServer() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Whether to check the cluster for a (live) server using our own server ID when starting up.
- isDefaultClusterDuplicateDetection() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
should duplicate detection headers be inserted in forwarded messages?
- isDefaultClusterForwardWhenNoConsumers() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
should messages be load balanced if there are no matching consumers on target?
- isDefaultCreateBindingsDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the server will create the bindings directory on start up
- isDefaultCreateJournalDir() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the journal directory will be created
- isDefaultDivertExclusive() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
whether this is an exclusive divert
- isDefaultFailoverOnServerShutdown() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Will this backup server come live on a normal server shutdown
- isDefaultFileDeploymentEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the server will load configuration from the configuration files
- isDefaultJmxManagementEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the management API is available via JMX
- isDefaultJournalLogWriteRate() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
Whether to log messages about the journal write rate
- isDefaultJournalSyncNonTransactional() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
if true wait for non transaction data to be synced to the journal before returning response to client.
- isDefaultJournalSyncTransactional() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
if true wait for transaction data to be synchronized to the journal before returning response to client
- isDefaultMaskPassword() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
This option controls whether passwords in server configuration need be masked.
- isDefaultMessageCounterEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that message counters are enabled
- isDefaultPersistDeliveryCountBeforeDelivery() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
True means that the delivery count is persisted before delivery.
- isDefaultPersistenceEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the server will use the file based journal for persistence.
- isDefaultPersistIdCache() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that ID's are persisted to the journal
- isDefaultResolveProtocols() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
If true then the HornetQ Server will make use of any Protocol Managers that are in available on the classpath.
- isDefaultRunSyncSpeedTest() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
XXX Only meant to be used by project developers
- isDefaultSecurityEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that security is enabled
- isDefaultSharedStore() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
'shared-store' applies to live and backup pairs, and it indicates if the live/backup pair share storage or if the data is replicated among them.
- isDefaultWildcardRoutingEnabled() - Static method in class org.hornetq.api.config.HornetQDefaultConfiguration
-
true means that the server supports wild card routing
- isDeleteDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can delete durable queues bound to the address.
- isDeleteNonDurableQueue() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can delete non-durable queues bound to the address.
- isDestroyed() - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
- isDuplicateDetection() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Return whether this cluster connection use duplicate detection.
- isDurable() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns true
if the queue is durable, false
else.
- isDurable() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns whether this queue is durable.
- isDurable() - Method in interface org.hornetq.api.core.Message
-
Returns whether this message is durable or not.
- isEquivalent(TransportConfiguration) - Method in class org.hornetq.api.core.TransportConfiguration
-
There's a case on ClusterConnections that we need to find an equivalent Connector and we can't
use a Netty Cluster Connection on an InVM ClusterConnection (inVM used on tests) for that
reason I need to test if the two instances of the TransportConfiguration are equivalent while
a test a connector against an acceptor
- isEquivalent(Map<String, Object>) - Method in interface org.hornetq.spi.core.remoting.Connector
-
If the configuration is equivalent to this connector, which means
if the parameter configuration is used to create a connection to a target
node, it will be the same node as of the connections made with this connector.
- isExclusive() - Method in interface org.hornetq.api.core.management.DivertControl
-
Returns whether this divert is exclusive.
- isExists() - Method in interface org.hornetq.api.core.client.ClientSession.BindingQuery
-
Returns true
if the binding exists, false
else.
- isExists() - Method in interface org.hornetq.api.core.client.ClientSession.QueueQuery
-
Returns true
if the queue exists, false
else.
- isExpired() - Method in interface org.hornetq.api.core.Message
-
Returns whether this message is expired or not.
- isFailoverOnInitialConnection() - Method in interface org.hornetq.api.core.client.ServerLocator
-
- isFailoverOnServerShutdown() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
returns if clients failover on a server shutdown
- isForwardWhenNoConsumers() - Method in interface org.hornetq.api.core.management.ClusterConnectionControl
-
Return whether this cluster connection forward messages when it has no local consumers.
- isHA() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Whether this server receives topology notifications from the cluster as servers join or leave
the cluster.
- isHA() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns whether this bridge is using high availability
- isJournalSyncNonTransactional() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether the journal is synchronized when receiving non-transactional data.
- isJournalSyncTransactional() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether the journal is synchronized when receiving transactional data.
- isLargeMessage() - Method in interface org.hornetq.api.core.Message
-
Returns whether this message is a large message or a regular message.
- isLastValueQueue() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- isManage() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can send management messages to the address.
- isMember(RemotingConnection) - Method in interface org.hornetq.api.core.client.TopologyMember
-
Returns true if this TopologyMember is the target of this remoting connection
- isMember(TransportConfiguration) - Method in interface org.hornetq.api.core.client.TopologyMember
-
Returns true if this configuration is the target of this remoting connection
- isMessageCounterEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether message counter is enabled for this server.
- isOperationResult(Message) - Static method in class org.hornetq.api.core.management.ManagementHelper
-
Returns whether the JMS message corresponds to the result of a management operation invocation.
- isPaging() - Method in interface org.hornetq.api.core.management.AddressControl
-
Returns whether this address is paging.
- isPaused() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns whether the queue is paused.
- isPersistDeliveryCountBeforeDelivery() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether delivery count is persisted before messages are delivered to the consumers.
- isPersistenceEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether this server is using persistence and store data.
- isPersistIDCache() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether message ID cache is persisted.
- isPreAcknowledge() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether messages will pre-acknowledged on the server before they are sent to the consumers or not.
- isReadyToHandle(HornetQBuffer) - Method in interface org.hornetq.spi.core.remoting.BufferDecoder
-
- isRollbackOnly() - Method in interface org.hornetq.api.core.client.ClientSession
-
Returns true
if the current transaction has been flagged to rollback, false
else.
- isSecurityEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether security is enabled for this server.
- isSend() - Method in class org.hornetq.api.core.management.RoleInfo
-
Returns whether this role can send messages to the address.
- isSendToDLAOnNoRoute() - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- isSharedStore() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether this server shares its data store with a corresponding live or backup server.
- isStarted() - Method in interface org.hornetq.api.core.management.HornetQComponentControl
-
Returns true
if this component is started, false
else.
- isStarted() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Return whether this server is started.
- isStarted() - Method in interface org.hornetq.spi.core.remoting.Connector
-
returns true if the connector is started, oterwise false.
- isTemporary() - Method in interface org.hornetq.api.core.management.QueueControl
-
Returns whether this queue is temporary.
- isUseDuplicateDetection() - Method in interface org.hornetq.api.core.management.BridgeControl
-
Returns whether this bridge is using duplicate detection.
- isUseGlobalPools() - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns whether this factory will use global thread pools (shared among all the factories in the same JVM)
or its own pools.
- isWildcardRoutingEnabled() - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Returns whether wildcard routing is supported by this server.
- isXA() - Method in interface org.hornetq.api.core.client.ClientSession
-
Return true
if the session supports XA, false
else.
- saveToOutputStream(OutputStream) - Method in interface org.hornetq.api.core.client.ClientMessage
-
Saves the content of the message to the OutputStream.
- select(int) - Method in interface org.hornetq.api.core.client.loadbalance.ConnectionLoadBalancingPolicy
-
Returns the selected index according to the policy implementation.
- select(int) - Method in class org.hornetq.api.core.client.loadbalance.FirstElementConnectionLoadBalancingPolicy
-
- select(int) - Method in class org.hornetq.api.core.client.loadbalance.RandomConnectionLoadBalancingPolicy
-
Returns a pseudo random number between 0
(inclusive) and max
exclusive.
- select(int) - Method in class org.hornetq.api.core.client.loadbalance.RandomStickyConnectionLoadBalancingPolicy
-
- select(int) - Method in class org.hornetq.api.core.client.loadbalance.RoundRobinConnectionLoadBalancingPolicy
-
- send(Message) - Method in interface org.hornetq.api.core.client.ClientProducer
-
Sends a message to an address.
- send(Message, SendAcknowledgementHandler) - Method in interface org.hornetq.api.core.client.ClientProducer
-
Sends a message to the specified address instead of the ClientProducer's address.
- send(SimpleString, Message) - Method in interface org.hornetq.api.core.client.ClientProducer
-
Sends a message to the specified address instead of the ClientProducer's address.
- send(SimpleString, Message, SendAcknowledgementHandler) - Method in interface org.hornetq.api.core.client.ClientProducer
-
Sends a message to the specified address instead of the ClientProducer's address.
- send(String, Message) - Method in interface org.hornetq.api.core.client.ClientProducer
-
Sends a message to the specified address instead of the ClientProducer's address.
- sendAcknowledged(Message) - Method in interface org.hornetq.api.core.client.SendAcknowledgementHandler
-
Notifies the client that a message sent asynchronously has been received by the server.
- SendAcknowledgementHandler - Interface in org.hornetq.api.core.client
-
A SendAcknowledgementHandler notifies a client when an message sent asynchronously has been
received by the server.
- sendMessagesToDeadLetterAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl
-
Sends all the message corresponding to the specified filter to this queue's dead letter address.
- sendMessageToDeadLetterAddress(long) - Method in interface org.hornetq.api.core.management.QueueControl
-
Sends the message corresponding to the specified message ID to this queue's dead letter address.
- sendQueueInfoToQueue(String, String) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
This method is used by HornetQ clustering and must not be called by HornetQ clients.
- ServerLocator - Interface in org.hornetq.api.core.client
-
The serverLocator locates a server, but beyond that it locates a server based on a list.
- SessionFailureListener - Interface in org.hornetq.api.core.client
-
A SessionFailureListener notifies the client when a failure occurred on the session.
- setAckBatchSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the acknowledgments batch size.
- setAddress(SimpleString) - Method in interface org.hornetq.api.core.Message
-
Sets the address to send this message to.
- setAutoGroup(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether producers created through this factory will automatically
assign a group ID to the messages they sent.
- setBlockOnAcknowledge(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether consumers created through this factory will block while
sending message acknowledgments or do it asynchronously.
- setBlockOnDurableSend(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether producers created through this factory will block while sending durable messages or do it asynchronously.
- setBlockOnNonDurableSend(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether producers created through this factory will block while sending non-durable messages or do it asynchronously.
- setBodyInputStream(InputStream) - Method in interface org.hornetq.api.core.client.ClientMessage
-
Sets the body's IntputStream.
- setBroadcastPeriod(long) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- setCacheLargeMessagesClient(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether large messages received by consumers created through this factory will be cached in temporary files or not.
- setCallFailoverTimeout(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the blocking call failover timeout.
- setCallTimeout(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the blocking call timeout.
- setClientFailureCheckPeriod(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the period (in milliseconds) used to check if a client has failed to receive pings from
the server.
- setCloseListeners(List<CloseListener>) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
- setCompressLargeMessage(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether to compress or not large messages.
- setConfirmationWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the size for the confirmation window buffer of clients using this factory.
- setConnectionLoadBalancingPolicyClassName(String) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the class name of the connection load balancing policy.
- setConnectionTTL(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets this factory's connections time-to-live.
- setConnectorInfos(List<String>) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- setConsumerMaxRate(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum rate of message consumption for consumers created through this factory.
- setConsumerWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the window size for flow control of the consumers created through this factory.
- setDeadLetterAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl
-
Sets the dead-letter address associated to this queue to the specified deadLetterAddress.
- setDeliveryCount(int) - Method in interface org.hornetq.api.core.client.ClientMessage
-
Sets the delivery count for this message.
- setDiscoveryInitialWaitTimeout(long) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- setDurable(boolean) - Method in interface org.hornetq.api.core.Message
-
Sets whether this message is durable or not.
- setExpiration(long) - Method in interface org.hornetq.api.core.Message
-
Sets the expiration of this message.
- setExpiryAddress(String) - Method in interface org.hornetq.api.core.management.QueueControl
-
Sets the expiry address associated to this queue to the specified expiryAddress.
- setFailoverOnInitialConnection(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the value for FailoverOnInitialReconnection
- setFailoverOnServerShutdown(boolean) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
do any clients failover on a server shutdown
- setFailureListeners(List<FailureListener>) - Method in interface org.hornetq.spi.core.protocol.RemotingConnection
-
set the failure listeners.
- setGroupID(String) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the group ID that will be set on each message sent through this factory.
- setInitialConnectAttempts(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum number of attempts to establish an initial connection.
- setInitialMessagePacketSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the initial size of messages created through this factory.
- setMaxRetryInterval(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum retry interval.
- setMessageCounterMaxDayCount(int) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Sets the maximum number of days kept in memory for message counter.
- setMessageCounterSamplePeriod(long) - Method in interface org.hornetq.api.core.management.HornetQServerControl
-
Sets the sample period to take message counter snapshot.
- setMessageHandler(MessageHandler) - Method in interface org.hornetq.api.core.client.ClientConsumer
-
Sets the MessageHandler for this consumer to consume messages asynchronously.
- setMinLargeMessageSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the large message size threshold.
- setName(String) - Method in class org.hornetq.api.core.BroadcastGroupConfiguration
-
- setName(String) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- setOutputStream(OutputStream) - Method in interface org.hornetq.api.core.client.ClientMessage
-
Sets the OutputStream that will receive the content of a message received in a non blocking way.
- setPageCacheMaxSize(int) - Method in class org.hornetq.api.core.management.AddressSettingsInfo
-
- setPreAcknowledge(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets to true
to pre-acknowledge consumed messages on the
server before they are sent to consumers, else set to false
to let clients acknowledge the message they consume.
- setPriority(byte) - Method in interface org.hornetq.api.core.Message
-
Sets the message priority.
- setProducerMaxRate(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum rate of message production for producers created through this factory.
- setProducerWindowSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Returns the window size for flow control of the producers created through this factory.
- setReconnectAttempts(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum number of attempts to retry connection in case of failure.
- setRefreshTimeout(long) - Method in class org.hornetq.api.core.DiscoveryGroupConfiguration
-
- setRetryInterval(long) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the time to retry connections created by this factory after failure.
- setRetryIntervalMultiplier(double) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the multiplier to apply to successive retry intervals.
- setScheduledThreadPoolMaxSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum size of the scheduled thread pool.
- setSendAcknowledgementHandler(SendAcknowledgementHandler) - Method in interface org.hornetq.api.core.client.ClientSession
-
Sets a SendAcknowledgementHandler
for this session.
- setThreadPoolMaxSize(int) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets the maximum size of the thread pool.
- setTimestamp(long) - Method in interface org.hornetq.api.core.Message
-
Sets the message timestamp.
- setUseGlobalPools(boolean) - Method in interface org.hornetq.api.core.client.ServerLocator
-
Sets whether this factory will use global thread pools (shared among all the factories in the same JVM)
or its own pools.
- setUserID(UUID) - Method in interface org.hornetq.api.core.Message
-
Sets the user ID
- splitHosts(String) - Static method in class org.hornetq.api.core.TransportConfiguration
-
Utility method for splitting a comma separated list of hosts
- start() - Method in interface org.hornetq.api.core.client.ClientSession
-
Starts the session.
- start() - Method in interface org.hornetq.api.core.management.HornetQComponentControl
-
Starts this component.
- start() - Method in interface org.hornetq.spi.core.remoting.Connector
-
starts the connector
- stop() - Method in interface org.hornetq.api.core.client.ClientSession
-
Stops the session.
- stop() - Method in interface org.hornetq.api.core.management.HornetQComponentControl
-
Stops this component.
- storeResult(Message, Object) - Static method in class org.hornetq.api.core.management.ManagementHelper
-
Used by HornetQ management service.
- STREAM_TYPE - Static variable in interface org.hornetq.api.core.Message
-