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
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 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 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
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
SimpleString routingName
SimpleString clusterName
SimpleString address
SimpleString filterString
long id
List<E> filterStrings
int numberOfConsumers
int distance
int code
List<E> headers
String body
VersionedStompFrameHandler handler
boolean disconnect
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
ServerLocator serverLocator
String clientID
int dupsOKBatchSize
int transactionBatchSize
boolean readOnly
String name
String address
SimpleString simpleAddress
boolean temporary
boolean queue
protected Object readResolve()
protected Object readResolve()
String name
protected Object readResolve()
Random random
Throwable cause
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.