public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
int queuePrefetch
int queueBrowserPrefetch
int topicPrefetch
int durableTopicPrefetch
int optimizeDurableTopicPrefetch
int inputStreamPrefetch
int maximumPendingMessageLimit
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
double collisionAvoidanceFactor
int maximumRedeliveries
long maximumRedeliveryDelay
long initialRedeliveryDelay
boolean useCollisionAvoidance
boolean useExponentialBackOff
double backOffMultiplier
long redeliveryDelay
Destination destination
ConsumerId consumerId
int consumerCount
DestinationInfo destinationInfo
Destination destination
ProducerId producerId
int producerCount
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
String name
TransactionManager transactionManager
boolean tmFromJndi
String tmJndiName
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
private Object readResolve()
long subKey
long topicKey
SubscriptionInfo info
long gcPosition
long lastAckPosition
long cursorPosition
private Object readResolve()
private Object readResolve()
ActiveMQDestination dest
long key
AtomicLong lastSeq
long cursorPosition
HashSet<E> preparedAcks
LinkedList<E> pendingCursorAdds
private Object readResolve()
TransactionId id
scala.collection.mutable.ListBuffer<A> commitActions
AtomicLong xaseqcounter
scala.Tuple2<T1,T2> xarecovery
long xacontainer_id
private Object readResolve()
org.apache.activemq.leveldb.LevelDBStore store
MessageId id
org.fusesource.hawtbuf.Buffer data
boolean syncNeeded
org.apache.activemq.leveldb.DataLocator locator
private Object readResolve()
private Object readResolve()
MessageId id
long queueKey
long queueSeq
int deliveries
private Object readResolve()
ActiveMQDestination id
long queue_key
private Object readResolve()
File directory
String logSuffix
long logSize
org.apache.activemq.leveldb.RecordLog.LogAppender current_appender
boolean verify_checksums
TreeMap<K,V> log_infos
org.apache.activemq.leveldb.RecordLogTestSupport recordLogTestSupport
org.apache.activemq.leveldb.util.TimeMetric max_log_write_latency
org.apache.activemq.leveldb.util.TimeMetric max_log_flush_latency
org.apache.activemq.leveldb.util.TimeMetric max_log_rotate_latency
scala.Function0<R> on_log_rotate
LRUCache<K,V> reader_cache
org.apache.activemq.leveldb.RecordLog.log_mutex$ log_mutex$module
org.apache.activemq.leveldb.RecordLog.LogAppender$ LogAppender$module
org.apache.activemq.leveldb.RecordLog.LogReader$ LogReader$module
long append_offset
org.apache.activemq.leveldb.RecordLog.LogInfo info
AtomicLong flushed_offset
org.fusesource.hawtbuf.DataByteArrayOutputStream write_buffer
private Object readResolve()
File file
long position
long length
private Object readResolve()
File file
long position
RandomAccessFile fd
FileChannel channel
private Object readResolve()
private Object readResolve()
byte LOG_HEADER_PREFIX
byte UOW_END_RECORD
int LOG_HEADER_SIZE
int BUFFER_SIZE
int BYPASS_BUFFER_SIZE
Logger log
private Object readResolve()
private Object readResolve()
long container
long seq
MessageAck ack
long sub
private Object readResolve()
private Object readResolve()
String name
String brokerUrl
String destinationType
String messageSelector
String destination
String acknowledgeMode
String userName
String password
String clientId
String subscriptionName
String subscriptionDurability
String noLocal
String useRAManagedTransaction
String maxSessions
String maxMessagesPerSessions
String enableBatch
String maxMessagesPerBatch
String trustStore
String trustStorePassword
String keyStore
String keyStorePassword
String keyStoreKeyPassword
RedeliveryPolicy redeliveryPolicy
boolean useJndi
ConnectionManager manager
ActiveMQManagedConnectionFactory factory
Reference reference
ActiveMQConnectionRequestInfo info
Logger log
String userName
String password
String serverUrl
String clientid
Boolean useInboundSession
RedeliveryPolicy redeliveryPolicy
ActiveMQPrefetchPolicy prefetchPolicy
Boolean useSessionArgs
String trustStore
String trustStorePassword
String keyStore
String keyStorePassword
String keyStoreKeyPassword
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
- if the object state could not be restoredClassNotFoundException
- if the object state could not be restoredprivate void writeObject(ObjectOutputStream out) throws IOException
IOException
- if the object cannot be serializedPrintWriter logWriter
Token currentToken
int[][] expectedTokenSequences
String[] tokenImage
String eol
int kind
int beginLine
int beginColumn
int endLine
int endColumn
String image
Token next
Token specialToken
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Externalizable.writeExternal(java.io.ObjectOutput)
String token
String symbolicName
boolean fatal
long maxKeepAge
ConcurrentMap<K,V> serviceGroups
BrokerService broker
HttpTransportServer transportConnector
TransportAcceptListener listener
HttpTransportFactory transportFactory
TextWireFormat wireFormat
ConcurrentMap<K,V> clients
long requestTimeout
HashMap<K,V> transportOptions
TransportAcceptListener listener
TransportAcceptListener listener
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
long bits
int length
LinkedList<E> list
int maxNumberOfArrays
int firstIndex
long lastInOrderBit
long longFirstIndex
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
String readTimeoutParameter
String readTimeoutRequestAtt
String oneShotParameter
long defaultReadTimeout
long maximumReadTimeout
long requestTimeout
String defaultContentType
HashMap<K,V> clients
HashSet<E> activeConsumers
boolean defaultTopicFlag
Destination defaultDestination
String destinationParameter
String typeParameter
String bodyParameter
boolean defaultMessagePersistent
int defaultMessagePriority
long defaultMessageTimeToLive
String destinationOptions
String style
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
IOException
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.