String name
long broadcastPeriod
BroadcastEndpointFactoryConfiguration endpointFactoryConfiguration
List<E> connectorInfos
private void readObject(ObjectInputStream in) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
HornetQExceptionType type
BroadcastEndpointFactory factory
byte[] data
String groupAddress
int groupPort
Random random
boolean first
int pos
protected Object readResolve()
private void readObject(ObjectInputStream is) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private Object writeReplace() throws ObjectStreamException
ObjectStreamException
Set<E> topologyListeners
boolean ha
boolean finalizeCheck
boolean clusterConnection
Set<E> factories
Set<E> connectingFactories
TransportConfiguration[] initialConnectors
DiscoveryGroupConfiguration discoveryGroupConfiguration
org.hornetq.core.client.impl.ServerLocatorImpl.StaticConnector staticConnector
Topology topology
String topologyArrayGuard
Pair<A,B>[] topologyArray
boolean receivedTopology
boolean compressLargeMessage
boolean cacheLargeMessagesClient
long clientFailureCheckPeriod
long connectionTTL
long callTimeout
long callFailoverTimeout
int minLargeMessageSize
int consumerWindowSize
int consumerMaxRate
int confirmationWindowSize
int producerWindowSize
int producerMaxRate
boolean blockOnAcknowledge
boolean blockOnDurableSend
boolean blockOnNonDurableSend
boolean autoGroup
boolean preAcknowledge
String connectionLoadBalancingPolicyClassName
int ackBatchSize
boolean useGlobalPools
int scheduledThreadPoolMaxSize
int threadPoolMaxSize
long retryInterval
double retryIntervalMultiplier
long maxRetryInterval
int reconnectAttempts
int initialConnectAttempts
boolean failoverOnInitialConnection
int initialMessagePacketSize
String stateGuard
List<E> incomingInterceptors
List<E> outgoingInterceptors
Executor startExecutor
AfterConnectInternalListener afterConnectListener
String groupID
String nodeID
TransportConfiguration clusterTransportConfiguration
Exception traceException
Set<E> topologyListeners
Object owner
Someone may argue this is not needed. But it's impossible to debug anything related to topology without knowing what node or what object missed a Topology update. Hence I added some information to locate debugging here.
Map<K,V> topology
String name
String queueName
String forwardingAddress
String filterString
List<E> staticConnectors
String discoveryGroupName
boolean ha
String transformerClassName
long retryInterval
double retryIntervalMultiplier
int initialConnectAttempts
int reconnectAttempts
int reconnectAttemptsOnSameNode
boolean useDuplicateDetection
int confirmationWindowSize
long clientFailureCheckPeriod
String user
String password
long connectionTTL
long maxRetryInterval
int minLargeMessageSize
long callTimeout
String name
String address
String connectorName
long clientFailureCheckPeriod
long connectionTTL
long retryInterval
double retryIntervalMultiplier
long maxRetryInterval
int initialConnectAttempts
int reconnectAttempts
long callTimeout
long callFailoverTimeout
boolean duplicateDetection
boolean forwardWhenNoConsumers
List<E> staticConnectors
String discoveryGroupName
int maxHops
int confirmationWindowSize
boolean allowDirectConnectionsOnly
int minLargeMessageSize
long clusterNotificationInterval
int clusterNotificationAttempts
String name
String nodeGroupName
boolean backup
boolean allowAutoFailBack
boolean sharedStore
boolean fileDeploymentEnabled
boolean persistenceEnabled
long fileDeploymentScanPeriod
boolean persistDeliveryCountBeforeDelivery
int scheduledThreadPoolMaxSize
int threadPoolMaxSize
long securityInvalidationInterval
boolean securityEnabled
boolean jmxManagementEnabled
String jmxDomain
long connectionTTLOverride
boolean asyncConnectionExecutionEnabled
long messageExpiryScanPeriod
int messageExpiryThreadPriority
int idCacheSize
boolean persistIDCache
List<E> incomingInterceptorClassNames
List<E> outgoingInterceptorClassNames
Map<K,V> connectorConfigs
Set<E> acceptorConfigs
List<E> bridgeConfigurations
List<E> divertConfigurations
List<E> clusterConfigurations
List<E> queueConfigurations
List<E> broadcastGroupConfigurations
Map<K,V> discoveryGroupConfigurations
String pagingDirectory
int maxConcurrentPageIO
String largeMessagesDirectory
String bindingsDirectory
boolean createBindingsDir
String journalDirectory
boolean createJournalDir
JournalType journalType
boolean journalSyncTransactional
boolean journalSyncNonTransactional
int journalCompactMinFiles
int journalCompactPercentage
int journalFileSize
int journalMinFiles
int journalMaxIO_AIO
int journalBufferTimeout_AIO
int journalBufferSize_AIO
int journalMaxIO_NIO
int journalBufferTimeout_NIO
int journalBufferSize_NIO
boolean logJournalWriteRate
int journalPerfBlastPages
boolean runSyncSpeedTest
boolean wildcardRoutingEnabled
boolean messageCounterEnabled
long messageCounterSamplePeriod
int messageCounterMaxDayHistory
long transactionTimeout
long transactionTimeoutScanPeriod
SimpleString managementAddress
SimpleString managementNotificationAddress
String clusterUser
String clusterPassword
long serverDumpInterval
boolean failoverOnServerShutdown
int memoryWarningThreshold
long memoryMeasureInterval
GroupingHandlerConfiguration groupingHandlerConfiguration
Map<K,V> addressesSettings
Map<K,V> securitySettings
List<E> connectorServiceConfigurations
long failbackDelay
boolean checkForLiveServer
boolean maskPassword
String replicationClusterName
boolean resolveProtocols
int maxSavedReplicatedJournalsSize
Set<E> backupServerConfigurations
String configurationUrl
boolean started
Token currentToken
int[][] expectedTokenSequences
String[] tokenImage
String eol
int kind
int beginLine
int beginColumn
int endLine
int endColumn
String image
Token next
Token specialToken
int errorCode
SimpleString routingName
SimpleString clusterName
SimpleString address
SimpleString filterString
long id
List<E> filterStrings
int numberOfConsumers
int distance
org.apache.qpid.proton.amqp.Symbol amqpError
int code
List<E> headers
String body
VersionedStompFrameHandler handler
boolean disconnect
org.jboss.logging.Logger log
protected Object readResolve()
String name
boolean send
boolean consume
boolean createDurableQueue
boolean deleteDurableQueue
boolean createNonDurableQueue
boolean deleteNonDurableQueue
boolean manage
protected Object readResolve()
SimpleString name
GroupingHandlerConfiguration.TYPE type
SimpleString address
long timeout
long groupTimeout
long reaperPeriod
AddressFullMessagePolicy addressFullMessagePolicy
Long maxSizeBytes
Long pageSizeBytes
Integer pageMaxCache
Boolean dropMessagesWhenFull
Integer maxDeliveryAttempts
Integer messageCounterHistoryDayLimit
Long redeliveryDelay
Double redeliveryMultiplier
Long maxRedeliveryDelay
SimpleString deadLetterAddress
SimpleString expiryAddress
Long expiryDelay
Boolean lastValueQueue
Long redistributionDelay
Boolean sendToDLAOnNoRoute
byte[] branchQualifier
int formatId
byte[] globalTransactionId
int hash
boolean hashCalculated
ServerLocator serverLocator
String clientID
int dupsOKBatchSize
int transactionBatchSize
boolean readOnly
String name
String address
SimpleString simpleAddress
boolean temporary
boolean queue
protected Object readResolve()
byte[] bytes
protected Object readResolve()
protected Object readResolve()
protected Object readResolve()
HornetQRAManagedConnectionFactory mcf
javax.resource.spi.ConnectionManager cm
Reference reference
ConcurrentHashSet<E> connections
HornetQResourceAdapter ra
javax.resource.spi.ConnectionManager cm
HornetQRAMCFProperties mcfProperties
HornetQConnectionFactory recoveryConnectionFactory
XARecoveryConfig resourceRecovery
String userName
String password
Boolean localTx
String transactionManagerLocatorClass
String transactionManagerLocatorMethod
int setupAttempts
long setupInterval
Hashtable<K,V> jndiParams
boolean useJNDI
boolean useMaskedPassword
String passwordCodec
boolean initialized
String jgroupsChannelLocatorClass
String jgroupsChannelRefName
javax.resource.spi.BootstrapContext ctx
HornetQRAProperties raProperties
String unparsedProperties
String unparsedConnectors
AtomicBoolean configured
Map<K,V> activations
HornetQConnectionFactory defaultHornetQConnectionFactory
HornetQConnectionFactory recoveryHornetQConnectionFactory
TransactionManager tm
String unparsedJndiParams
RecoveryManager recoveryManager
boolean useAutoRecovery
List<E> managedConnectionFactories
String strConnectorClassName
String strConnectionParameters
HornetQResourceAdapter ra
String connectionFactoryLookup
String destination
String destinationType
String messageSelector
int acknowledgeMode
boolean subscriptionDurability
String subscriptionName
boolean shareSubscriptions
String user
String password
Integer maxSession
Integer transactionTimeout
Boolean useJNDI
String jndiParams
Hashtable<K,V> parsedJndiParams
Boolean localTx
Integer setupAttempts
Long setupInterval
String name
protected Object readResolve()
Random random
Throwable cause
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.