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
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
Token currentToken
int[][] expectedTokenSequences
String[] tokenImage
String eol
int kind
int beginLine
int beginColumn
int endLine
int endColumn
String image
Token next
Token specialToken
String name
boolean send
boolean consume
boolean createDurableQueue
boolean deleteDurableQueue
boolean createNonDurableQueue
boolean deleteNonDurableQueue
boolean manage
protected HornetQUtilBundle_$bundle readResolve()
Random random
Throwable cause
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.