Path Lines of Code src/AdvisoryConsumer.cs 106 src/BrokerException.cs 57 src/Commands/ActiveMQBlobMessage.cs 31 src/Commands/ActiveMQBytesMessage.cs 575 src/Commands/ActiveMQDestination.cs 369 src/Commands/ActiveMQMapMessage.cs 89 src/Commands/ActiveMQMessage.cs 316 src/Commands/ActiveMQObjectMessage.cs 109 src/Commands/ActiveMQQueue.cs 44 src/Commands/ActiveMQStreamMessage.cs 750 src/Commands/ActiveMQTempDestination.cs 54 src/Commands/ActiveMQTempQueue.cs 47 src/Commands/ActiveMQTempTopic.cs 46 src/Commands/ActiveMQTextMessage.cs 110 src/Commands/ActiveMQTopic.cs 44 src/Commands/BaseCommand.cs 298 src/Commands/BaseDataStructure.cs 67 src/Commands/BooleanExpression.cs 6 src/Commands/BrokerError.cs 63 src/Commands/BrokerId.cs 43 src/Commands/BrokerInfo.cs 110 src/Commands/Command.cs 119 src/Commands/ConnectionControl.cs 89 src/Commands/ConnectionError.cs 40 src/Commands/ConnectionId.cs 58 src/Commands/ConnectionInfo.cs 103 src/Commands/ConsumerControl.cs 75 src/Commands/ConsumerId.cs 85 src/Commands/ConsumerInfo.cs 159 src/Commands/ControlCommand.cs 33 src/Commands/DataArrayResponse.cs 22 src/Commands/DataResponse.cs 22 src/Commands/DataStructure.cs 9 src/Commands/DataStructureSupport.cs 22 src/Commands/DestinationInfo.cs 85 src/Commands/DiscoveryEvent.cs 29 src/Commands/ExceptionResponse.cs 22 src/Commands/FlushCommand.cs 24 src/Commands/IntegerResponse.cs 22 src/Commands/JournalQueueAck.cs 29 src/Commands/JournalTopicAck.cs 57 src/Commands/JournalTrace.cs 22 src/Commands/JournalTransaction.cs 36 src/Commands/KeepAliveInfo.cs 24 src/Commands/LastPartialCommand.cs 15 src/Commands/LocalTransactionId.cs 54 src/Commands/MarshallAware.cs 13 src/Commands/Message.cs 286 src/Commands/MessageAck.cs 100 src/Commands/MessageDispatch.cs 110 src/Commands/MessageDispatchNotification.cs 54 src/Commands/MessageId.cs 119 src/Commands/MessagePull.cs 61 src/Commands/MessageReference.cs 6 src/Commands/NetworkBridgeFilter.cs 36 src/Commands/PartialCommand.cs 29 src/Commands/ProducerAck.cs 40 src/Commands/ProducerId.cs 95 src/Commands/ProducerInfo.cs 61 src/Commands/RemoveInfo.cs 52 src/Commands/RemoveSubscriptionInfo.cs 47 src/Commands/ReplayCommand.cs 40 src/Commands/Response.cs 33 src/Commands/SessionId.cs 83 src/Commands/SessionInfo.cs 40 src/Commands/ShutdownInfo.cs 24 src/Commands/SubscriptionInfo.cs 50 src/Commands/TransactionId.cs 31 src/Commands/TransactionInfo.cs 75 src/Commands/TrustedClassFilter.cs 34 src/Commands/WireFormatInfo.cs 165 src/Commands/XATransactionId.cs 69 src/Commands/Xid.cs 6 src/CompressionPolicy.cs 20 src/Connection.cs 1261 src/ConnectionClosedException.cs 34 src/ConnectionFactory.cs 454 src/ConnectionFailedException.cs 34 src/ConnectionMetaData.cs 70 src/ConsumerClosedException.cs 34 src/DestinationFilter.cs 13 src/ICompressionPolicy.cs 10 src/IDispatcher.cs 9 src/INmsDeserializationPolicy.cs 9 src/IOException.cs 19 src/ISynchronization.cs 10 src/MessageConsumer.cs 1590 src/MessageProducer.cs 346 src/NetTxConnection.cs 85 src/NetTxConnectionFactory.cs 56 src/NetTxMessageConsumer.cs 85 src/NetTxRecoveryPolicy.cs 87 src/NetTxSession.cs 133 src/NetTxTransactionContext.cs 480 src/NmsConsumer.cs 90 src/NmsContext.cs 427 src/NmsDefaultDeserializationPolicy.cs 74 src/NmsProducer.cs 335 src/OpenWire/BaseDataStreamMarshaller.cs 584 src/OpenWire/BooleanStream.cs 90 src/OpenWire/IMarshallerFactory.cs 7 src/OpenWire/OpenWireFormat.cs 311 src/OpenWire/V1/ActiveMQBlobMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V1/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V1/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V1/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V1/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V1/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V1/BaseCommandMarshaller.cs 44 src/OpenWire/V1/BrokerIdMarshaller.cs 48 src/OpenWire/V1/BrokerInfoMarshaller.cs 98 src/OpenWire/V1/ConnectionControlMarshaller.cs 67 src/OpenWire/V1/ConnectionErrorMarshaller.cs 53 src/OpenWire/V1/ConnectionIdMarshaller.cs 48 src/OpenWire/V1/ConnectionInfoMarshaller.cs 98 src/OpenWire/V1/ConsumerControlMarshaller.cs 57 src/OpenWire/V1/ConsumerIdMarshaller.cs 58 src/OpenWire/V1/ConsumerInfoMarshaller.cs 145 src/OpenWire/V1/ControlCommandMarshaller.cs 48 src/OpenWire/V1/DataArrayResponseMarshaller.cs 68 src/OpenWire/V1/DataResponseMarshaller.cs 48 src/OpenWire/V1/DataStructureSupportMarshaller.cs 21 src/OpenWire/V1/DestinationInfoMarshaller.cs 87 src/OpenWire/V1/DiscoveryEventMarshaller.cs 53 src/OpenWire/V1/ExceptionResponseMarshaller.cs 48 src/OpenWire/V1/FlushCommandMarshaller.cs 38 src/OpenWire/V1/IntegerResponseMarshaller.cs 46 src/OpenWire/V1/JournalQueueAckMarshaller.cs 53 src/OpenWire/V1/JournalTopicAckMarshaller.cs 73 src/OpenWire/V1/JournalTraceMarshaller.cs 48 src/OpenWire/V1/JournalTransactionMarshaller.cs 57 src/OpenWire/V1/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V1/LastPartialCommandMarshaller.cs 38 src/OpenWire/V1/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V1/MarshallerFactory.cs 66 src/OpenWire/V1/MessageAckMarshaller.cs 76 src/OpenWire/V1/MessageDispatchMarshaller.cs 62 src/OpenWire/V1/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V1/MessageIdMarshaller.cs 58 src/OpenWire/V1/MessageMarshaller.cs 193 src/OpenWire/V1/MessagePullMarshaller.cs 58 src/OpenWire/V1/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V1/PartialCommandMarshaller.cs 60 src/OpenWire/V1/ProducerAckMarshaller.cs 38 src/OpenWire/V1/ProducerIdMarshaller.cs 58 src/OpenWire/V1/ProducerInfoMarshaller.cs 78 src/OpenWire/V1/RemoveInfoMarshaller.cs 48 src/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V1/ReplayCommandMarshaller.cs 50 src/OpenWire/V1/ResponseMarshaller.cs 46 src/OpenWire/V1/SessionIdMarshaller.cs 53 src/OpenWire/V1/SessionInfoMarshaller.cs 48 src/OpenWire/V1/ShutdownInfoMarshaller.cs 38 src/OpenWire/V1/SubscriptionInfoMarshaller.cs 63 src/OpenWire/V1/TransactionIdMarshaller.cs 30 src/OpenWire/V1/TransactionInfoMarshaller.cs 57 src/OpenWire/V1/WireFormatInfoMarshaller.cs 72 src/OpenWire/V1/XATransactionIdMarshaller.cs 73 src/OpenWire/V10/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V10/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V10/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V10/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V10/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V10/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V10/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V10/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V10/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V10/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V10/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V10/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V10/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V10/BaseCommandMarshaller.cs 44 src/OpenWire/V10/BrokerIdMarshaller.cs 48 src/OpenWire/V10/BrokerInfoMarshaller.cs 123 src/OpenWire/V10/ConnectionControlMarshaller.cs 96 src/OpenWire/V10/ConnectionErrorMarshaller.cs 53 src/OpenWire/V10/ConnectionIdMarshaller.cs 48 src/OpenWire/V10/ConnectionInfoMarshaller.cs 118 src/OpenWire/V10/ConsumerControlMarshaller.cs 77 src/OpenWire/V10/ConsumerIdMarshaller.cs 58 src/OpenWire/V10/ConsumerInfoMarshaller.cs 175 src/OpenWire/V10/ControlCommandMarshaller.cs 48 src/OpenWire/V10/DataArrayResponseMarshaller.cs 68 src/OpenWire/V10/DataResponseMarshaller.cs 48 src/OpenWire/V10/DestinationInfoMarshaller.cs 87 src/OpenWire/V10/DiscoveryEventMarshaller.cs 53 src/OpenWire/V10/ExceptionResponseMarshaller.cs 48 src/OpenWire/V10/FlushCommandMarshaller.cs 38 src/OpenWire/V10/IntegerResponseMarshaller.cs 46 src/OpenWire/V10/JournalQueueAckMarshaller.cs 53 src/OpenWire/V10/JournalTopicAckMarshaller.cs 73 src/OpenWire/V10/JournalTraceMarshaller.cs 48 src/OpenWire/V10/JournalTransactionMarshaller.cs 57 src/OpenWire/V10/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V10/LastPartialCommandMarshaller.cs 38 src/OpenWire/V10/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V10/MarshallerFactory.cs 66 src/OpenWire/V10/MessageAckMarshaller.cs 81 src/OpenWire/V10/MessageDispatchMarshaller.cs 62 src/OpenWire/V10/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V10/MessageIdMarshaller.cs 63 src/OpenWire/V10/MessageMarshaller.cs 238 src/OpenWire/V10/MessagePullMarshaller.cs 68 src/OpenWire/V10/NetworkBridgeFilterMarshaller.cs 56 src/OpenWire/V10/PartialCommandMarshaller.cs 60 src/OpenWire/V10/ProducerAckMarshaller.cs 52 src/OpenWire/V10/ProducerIdMarshaller.cs 58 src/OpenWire/V10/ProducerInfoMarshaller.cs 87 src/OpenWire/V10/RemoveInfoMarshaller.cs 53 src/OpenWire/V10/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V10/ReplayCommandMarshaller.cs 50 src/OpenWire/V10/ResponseMarshaller.cs 46 src/OpenWire/V10/SessionIdMarshaller.cs 53 src/OpenWire/V10/SessionInfoMarshaller.cs 48 src/OpenWire/V10/ShutdownInfoMarshaller.cs 38 src/OpenWire/V10/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V10/TransactionIdMarshaller.cs 30 src/OpenWire/V10/TransactionInfoMarshaller.cs 57 src/OpenWire/V10/WireFormatInfoMarshaller.cs 72 src/OpenWire/V10/XATransactionIdMarshaller.cs 73 src/OpenWire/V2/ActiveMQBlobMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V2/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V2/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V2/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V2/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V2/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V2/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V2/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V2/BaseCommandMarshaller.cs 44 src/OpenWire/V2/BrokerIdMarshaller.cs 48 src/OpenWire/V2/BrokerInfoMarshaller.cs 113 src/OpenWire/V2/ConnectionControlMarshaller.cs 67 src/OpenWire/V2/ConnectionErrorMarshaller.cs 53 src/OpenWire/V2/ConnectionIdMarshaller.cs 48 src/OpenWire/V2/ConnectionInfoMarshaller.cs 103 src/OpenWire/V2/ConsumerControlMarshaller.cs 72 src/OpenWire/V2/ConsumerIdMarshaller.cs 58 src/OpenWire/V2/ConsumerInfoMarshaller.cs 145 src/OpenWire/V2/ControlCommandMarshaller.cs 48 src/OpenWire/V2/DataArrayResponseMarshaller.cs 68 src/OpenWire/V2/DataResponseMarshaller.cs 48 src/OpenWire/V2/DestinationInfoMarshaller.cs 87 src/OpenWire/V2/DiscoveryEventMarshaller.cs 53 src/OpenWire/V2/ExceptionResponseMarshaller.cs 48 src/OpenWire/V2/FlushCommandMarshaller.cs 38 src/OpenWire/V2/IntegerResponseMarshaller.cs 46 src/OpenWire/V2/JournalQueueAckMarshaller.cs 53 src/OpenWire/V2/JournalTopicAckMarshaller.cs 73 src/OpenWire/V2/JournalTraceMarshaller.cs 48 src/OpenWire/V2/JournalTransactionMarshaller.cs 57 src/OpenWire/V2/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V2/LastPartialCommandMarshaller.cs 38 src/OpenWire/V2/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V2/MarshallerFactory.cs 66 src/OpenWire/V2/MessageAckMarshaller.cs 76 src/OpenWire/V2/MessageDispatchMarshaller.cs 62 src/OpenWire/V2/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V2/MessageIdMarshaller.cs 58 src/OpenWire/V2/MessageMarshaller.cs 198 src/OpenWire/V2/MessagePullMarshaller.cs 58 src/OpenWire/V2/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V2/PartialCommandMarshaller.cs 60 src/OpenWire/V2/ProducerAckMarshaller.cs 38 src/OpenWire/V2/ProducerIdMarshaller.cs 58 src/OpenWire/V2/ProducerInfoMarshaller.cs 83 src/OpenWire/V2/RemoveInfoMarshaller.cs 48 src/OpenWire/V2/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V2/ReplayCommandMarshaller.cs 50 src/OpenWire/V2/ResponseMarshaller.cs 46 src/OpenWire/V2/SessionIdMarshaller.cs 53 src/OpenWire/V2/SessionInfoMarshaller.cs 48 src/OpenWire/V2/ShutdownInfoMarshaller.cs 38 src/OpenWire/V2/SubscriptionInfoMarshaller.cs 63 src/OpenWire/V2/TransactionIdMarshaller.cs 30 src/OpenWire/V2/TransactionInfoMarshaller.cs 57 src/OpenWire/V2/WireFormatInfoMarshaller.cs 72 src/OpenWire/V2/XATransactionIdMarshaller.cs 73 src/OpenWire/V3/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V3/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V3/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V3/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V3/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V3/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V3/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V3/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V3/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V3/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V3/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V3/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V3/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V3/BaseCommandMarshaller.cs 44 src/OpenWire/V3/BrokerIdMarshaller.cs 48 src/OpenWire/V3/BrokerInfoMarshaller.cs 123 src/OpenWire/V3/ConnectionControlMarshaller.cs 67 src/OpenWire/V3/ConnectionErrorMarshaller.cs 53 src/OpenWire/V3/ConnectionIdMarshaller.cs 48 src/OpenWire/V3/ConnectionInfoMarshaller.cs 103 src/OpenWire/V3/ConsumerControlMarshaller.cs 72 src/OpenWire/V3/ConsumerIdMarshaller.cs 58 src/OpenWire/V3/ConsumerInfoMarshaller.cs 145 src/OpenWire/V3/ControlCommandMarshaller.cs 48 src/OpenWire/V3/DataArrayResponseMarshaller.cs 68 src/OpenWire/V3/DataResponseMarshaller.cs 48 src/OpenWire/V3/DestinationInfoMarshaller.cs 87 src/OpenWire/V3/DiscoveryEventMarshaller.cs 53 src/OpenWire/V3/ExceptionResponseMarshaller.cs 48 src/OpenWire/V3/FlushCommandMarshaller.cs 38 src/OpenWire/V3/IntegerResponseMarshaller.cs 46 src/OpenWire/V3/JournalQueueAckMarshaller.cs 53 src/OpenWire/V3/JournalTopicAckMarshaller.cs 73 src/OpenWire/V3/JournalTraceMarshaller.cs 48 src/OpenWire/V3/JournalTransactionMarshaller.cs 57 src/OpenWire/V3/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V3/LastPartialCommandMarshaller.cs 38 src/OpenWire/V3/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V3/MarshallerFactory.cs 66 src/OpenWire/V3/MessageAckMarshaller.cs 76 src/OpenWire/V3/MessageDispatchMarshaller.cs 62 src/OpenWire/V3/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V3/MessageIdMarshaller.cs 58 src/OpenWire/V3/MessageMarshaller.cs 233 src/OpenWire/V3/MessagePullMarshaller.cs 68 src/OpenWire/V3/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V3/PartialCommandMarshaller.cs 60 src/OpenWire/V3/ProducerAckMarshaller.cs 52 src/OpenWire/V3/ProducerIdMarshaller.cs 58 src/OpenWire/V3/ProducerInfoMarshaller.cs 87 src/OpenWire/V3/RemoveInfoMarshaller.cs 48 src/OpenWire/V3/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V3/ReplayCommandMarshaller.cs 50 src/OpenWire/V3/ResponseMarshaller.cs 46 src/OpenWire/V3/SessionIdMarshaller.cs 53 src/OpenWire/V3/SessionInfoMarshaller.cs 48 src/OpenWire/V3/ShutdownInfoMarshaller.cs 38 src/OpenWire/V3/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V3/TransactionIdMarshaller.cs 30 src/OpenWire/V3/TransactionInfoMarshaller.cs 57 src/OpenWire/V3/WireFormatInfoMarshaller.cs 72 src/OpenWire/V3/XATransactionIdMarshaller.cs 73 src/OpenWire/V4/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V4/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V4/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V4/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V4/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V4/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V4/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V4/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V4/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V4/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V4/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V4/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V4/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V4/BaseCommandMarshaller.cs 44 src/OpenWire/V4/BrokerIdMarshaller.cs 48 src/OpenWire/V4/BrokerInfoMarshaller.cs 123 src/OpenWire/V4/ConnectionControlMarshaller.cs 67 src/OpenWire/V4/ConnectionErrorMarshaller.cs 53 src/OpenWire/V4/ConnectionIdMarshaller.cs 48 src/OpenWire/V4/ConnectionInfoMarshaller.cs 103 src/OpenWire/V4/ConsumerControlMarshaller.cs 72 src/OpenWire/V4/ConsumerIdMarshaller.cs 58 src/OpenWire/V4/ConsumerInfoMarshaller.cs 170 src/OpenWire/V4/ControlCommandMarshaller.cs 48 src/OpenWire/V4/DataArrayResponseMarshaller.cs 68 src/OpenWire/V4/DataResponseMarshaller.cs 48 src/OpenWire/V4/DestinationInfoMarshaller.cs 87 src/OpenWire/V4/DiscoveryEventMarshaller.cs 53 src/OpenWire/V4/ExceptionResponseMarshaller.cs 48 src/OpenWire/V4/FlushCommandMarshaller.cs 38 src/OpenWire/V4/IntegerResponseMarshaller.cs 46 src/OpenWire/V4/JournalQueueAckMarshaller.cs 53 src/OpenWire/V4/JournalTopicAckMarshaller.cs 73 src/OpenWire/V4/JournalTraceMarshaller.cs 48 src/OpenWire/V4/JournalTransactionMarshaller.cs 57 src/OpenWire/V4/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V4/LastPartialCommandMarshaller.cs 38 src/OpenWire/V4/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V4/MarshallerFactory.cs 66 src/OpenWire/V4/MessageAckMarshaller.cs 76 src/OpenWire/V4/MessageDispatchMarshaller.cs 62 src/OpenWire/V4/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V4/MessageIdMarshaller.cs 58 src/OpenWire/V4/MessageMarshaller.cs 233 src/OpenWire/V4/MessagePullMarshaller.cs 68 src/OpenWire/V4/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V4/PartialCommandMarshaller.cs 60 src/OpenWire/V4/ProducerAckMarshaller.cs 52 src/OpenWire/V4/ProducerIdMarshaller.cs 58 src/OpenWire/V4/ProducerInfoMarshaller.cs 87 src/OpenWire/V4/RemoveInfoMarshaller.cs 48 src/OpenWire/V4/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V4/ReplayCommandMarshaller.cs 50 src/OpenWire/V4/ResponseMarshaller.cs 46 src/OpenWire/V4/SessionIdMarshaller.cs 53 src/OpenWire/V4/SessionInfoMarshaller.cs 48 src/OpenWire/V4/ShutdownInfoMarshaller.cs 38 src/OpenWire/V4/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V4/TransactionIdMarshaller.cs 30 src/OpenWire/V4/TransactionInfoMarshaller.cs 57 src/OpenWire/V4/WireFormatInfoMarshaller.cs 72 src/OpenWire/V4/XATransactionIdMarshaller.cs 73 src/OpenWire/V5/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V5/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V5/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V5/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V5/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V5/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V5/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V5/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V5/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V5/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V5/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V5/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V5/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V5/BaseCommandMarshaller.cs 44 src/OpenWire/V5/BrokerIdMarshaller.cs 48 src/OpenWire/V5/BrokerInfoMarshaller.cs 123 src/OpenWire/V5/ConnectionControlMarshaller.cs 67 src/OpenWire/V5/ConnectionErrorMarshaller.cs 53 src/OpenWire/V5/ConnectionIdMarshaller.cs 48 src/OpenWire/V5/ConnectionInfoMarshaller.cs 103 src/OpenWire/V5/ConsumerControlMarshaller.cs 72 src/OpenWire/V5/ConsumerIdMarshaller.cs 58 src/OpenWire/V5/ConsumerInfoMarshaller.cs 170 src/OpenWire/V5/ControlCommandMarshaller.cs 48 src/OpenWire/V5/DataArrayResponseMarshaller.cs 68 src/OpenWire/V5/DataResponseMarshaller.cs 48 src/OpenWire/V5/DestinationInfoMarshaller.cs 87 src/OpenWire/V5/DiscoveryEventMarshaller.cs 53 src/OpenWire/V5/ExceptionResponseMarshaller.cs 48 src/OpenWire/V5/FlushCommandMarshaller.cs 38 src/OpenWire/V5/IntegerResponseMarshaller.cs 46 src/OpenWire/V5/JournalQueueAckMarshaller.cs 53 src/OpenWire/V5/JournalTopicAckMarshaller.cs 73 src/OpenWire/V5/JournalTraceMarshaller.cs 48 src/OpenWire/V5/JournalTransactionMarshaller.cs 57 src/OpenWire/V5/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V5/LastPartialCommandMarshaller.cs 38 src/OpenWire/V5/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V5/MarshallerFactory.cs 66 src/OpenWire/V5/MessageAckMarshaller.cs 76 src/OpenWire/V5/MessageDispatchMarshaller.cs 62 src/OpenWire/V5/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V5/MessageIdMarshaller.cs 58 src/OpenWire/V5/MessageMarshaller.cs 233 src/OpenWire/V5/MessagePullMarshaller.cs 68 src/OpenWire/V5/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V5/PartialCommandMarshaller.cs 60 src/OpenWire/V5/ProducerAckMarshaller.cs 52 src/OpenWire/V5/ProducerIdMarshaller.cs 58 src/OpenWire/V5/ProducerInfoMarshaller.cs 87 src/OpenWire/V5/RemoveInfoMarshaller.cs 53 src/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V5/ReplayCommandMarshaller.cs 50 src/OpenWire/V5/ResponseMarshaller.cs 46 src/OpenWire/V5/SessionIdMarshaller.cs 53 src/OpenWire/V5/SessionInfoMarshaller.cs 48 src/OpenWire/V5/ShutdownInfoMarshaller.cs 38 src/OpenWire/V5/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V5/TransactionIdMarshaller.cs 30 src/OpenWire/V5/TransactionInfoMarshaller.cs 57 src/OpenWire/V5/WireFormatInfoMarshaller.cs 72 src/OpenWire/V5/XATransactionIdMarshaller.cs 73 src/OpenWire/V6/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V6/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V6/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V6/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V6/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V6/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V6/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V6/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V6/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V6/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V6/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V6/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V6/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V6/BaseCommandMarshaller.cs 44 src/OpenWire/V6/BrokerIdMarshaller.cs 48 src/OpenWire/V6/BrokerInfoMarshaller.cs 123 src/OpenWire/V6/ConnectionControlMarshaller.cs 83 src/OpenWire/V6/ConnectionErrorMarshaller.cs 53 src/OpenWire/V6/ConnectionIdMarshaller.cs 48 src/OpenWire/V6/ConnectionInfoMarshaller.cs 113 src/OpenWire/V6/ConsumerControlMarshaller.cs 77 src/OpenWire/V6/ConsumerIdMarshaller.cs 58 src/OpenWire/V6/ConsumerInfoMarshaller.cs 170 src/OpenWire/V6/ControlCommandMarshaller.cs 48 src/OpenWire/V6/DataArrayResponseMarshaller.cs 68 src/OpenWire/V6/DataResponseMarshaller.cs 48 src/OpenWire/V6/DestinationInfoMarshaller.cs 87 src/OpenWire/V6/DiscoveryEventMarshaller.cs 53 src/OpenWire/V6/ExceptionResponseMarshaller.cs 48 src/OpenWire/V6/FlushCommandMarshaller.cs 38 src/OpenWire/V6/IntegerResponseMarshaller.cs 46 src/OpenWire/V6/JournalQueueAckMarshaller.cs 53 src/OpenWire/V6/JournalTopicAckMarshaller.cs 73 src/OpenWire/V6/JournalTraceMarshaller.cs 48 src/OpenWire/V6/JournalTransactionMarshaller.cs 57 src/OpenWire/V6/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V6/LastPartialCommandMarshaller.cs 38 src/OpenWire/V6/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V6/MarshallerFactory.cs 66 src/OpenWire/V6/MessageAckMarshaller.cs 76 src/OpenWire/V6/MessageDispatchMarshaller.cs 62 src/OpenWire/V6/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V6/MessageIdMarshaller.cs 58 src/OpenWire/V6/MessageMarshaller.cs 233 src/OpenWire/V6/MessagePullMarshaller.cs 68 src/OpenWire/V6/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V6/PartialCommandMarshaller.cs 60 src/OpenWire/V6/ProducerAckMarshaller.cs 52 src/OpenWire/V6/ProducerIdMarshaller.cs 58 src/OpenWire/V6/ProducerInfoMarshaller.cs 87 src/OpenWire/V6/RemoveInfoMarshaller.cs 53 src/OpenWire/V6/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V6/ReplayCommandMarshaller.cs 50 src/OpenWire/V6/ResponseMarshaller.cs 46 src/OpenWire/V6/SessionIdMarshaller.cs 53 src/OpenWire/V6/SessionInfoMarshaller.cs 48 src/OpenWire/V6/ShutdownInfoMarshaller.cs 38 src/OpenWire/V6/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V6/TransactionIdMarshaller.cs 30 src/OpenWire/V6/TransactionInfoMarshaller.cs 57 src/OpenWire/V6/WireFormatInfoMarshaller.cs 72 src/OpenWire/V6/XATransactionIdMarshaller.cs 73 src/OpenWire/V7/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V7/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V7/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V7/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V7/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V7/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V7/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V7/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V7/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V7/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V7/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V7/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V7/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V7/BaseCommandMarshaller.cs 44 src/OpenWire/V7/BrokerIdMarshaller.cs 48 src/OpenWire/V7/BrokerInfoMarshaller.cs 123 src/OpenWire/V7/ConnectionControlMarshaller.cs 83 src/OpenWire/V7/ConnectionErrorMarshaller.cs 53 src/OpenWire/V7/ConnectionIdMarshaller.cs 48 src/OpenWire/V7/ConnectionInfoMarshaller.cs 113 src/OpenWire/V7/ConsumerControlMarshaller.cs 77 src/OpenWire/V7/ConsumerIdMarshaller.cs 58 src/OpenWire/V7/ConsumerInfoMarshaller.cs 170 src/OpenWire/V7/ControlCommandMarshaller.cs 48 src/OpenWire/V7/DataArrayResponseMarshaller.cs 68 src/OpenWire/V7/DataResponseMarshaller.cs 48 src/OpenWire/V7/DestinationInfoMarshaller.cs 87 src/OpenWire/V7/DiscoveryEventMarshaller.cs 53 src/OpenWire/V7/ExceptionResponseMarshaller.cs 48 src/OpenWire/V7/FlushCommandMarshaller.cs 38 src/OpenWire/V7/IntegerResponseMarshaller.cs 46 src/OpenWire/V7/JournalQueueAckMarshaller.cs 53 src/OpenWire/V7/JournalTopicAckMarshaller.cs 73 src/OpenWire/V7/JournalTraceMarshaller.cs 48 src/OpenWire/V7/JournalTransactionMarshaller.cs 57 src/OpenWire/V7/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V7/LastPartialCommandMarshaller.cs 38 src/OpenWire/V7/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V7/MarshallerFactory.cs 66 src/OpenWire/V7/MessageAckMarshaller.cs 81 src/OpenWire/V7/MessageDispatchMarshaller.cs 62 src/OpenWire/V7/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V7/MessageIdMarshaller.cs 58 src/OpenWire/V7/MessageMarshaller.cs 233 src/OpenWire/V7/MessagePullMarshaller.cs 68 src/OpenWire/V7/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V7/PartialCommandMarshaller.cs 60 src/OpenWire/V7/ProducerAckMarshaller.cs 52 src/OpenWire/V7/ProducerIdMarshaller.cs 58 src/OpenWire/V7/ProducerInfoMarshaller.cs 87 src/OpenWire/V7/RemoveInfoMarshaller.cs 53 src/OpenWire/V7/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V7/ReplayCommandMarshaller.cs 50 src/OpenWire/V7/ResponseMarshaller.cs 46 src/OpenWire/V7/SessionIdMarshaller.cs 53 src/OpenWire/V7/SessionInfoMarshaller.cs 48 src/OpenWire/V7/ShutdownInfoMarshaller.cs 38 src/OpenWire/V7/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V7/TransactionIdMarshaller.cs 30 src/OpenWire/V7/TransactionInfoMarshaller.cs 57 src/OpenWire/V7/WireFormatInfoMarshaller.cs 72 src/OpenWire/V7/XATransactionIdMarshaller.cs 73 src/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V8/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V8/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V8/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V8/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V8/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V8/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V8/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V8/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V8/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V8/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V8/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V8/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V8/BaseCommandMarshaller.cs 44 src/OpenWire/V8/BrokerIdMarshaller.cs 48 src/OpenWire/V8/BrokerInfoMarshaller.cs 123 src/OpenWire/V8/ConnectionControlMarshaller.cs 96 src/OpenWire/V8/ConnectionErrorMarshaller.cs 53 src/OpenWire/V8/ConnectionIdMarshaller.cs 48 src/OpenWire/V8/ConnectionInfoMarshaller.cs 118 src/OpenWire/V8/ConsumerControlMarshaller.cs 77 src/OpenWire/V8/ConsumerIdMarshaller.cs 58 src/OpenWire/V8/ConsumerInfoMarshaller.cs 170 src/OpenWire/V8/ControlCommandMarshaller.cs 48 src/OpenWire/V8/DataArrayResponseMarshaller.cs 68 src/OpenWire/V8/DataResponseMarshaller.cs 48 src/OpenWire/V8/DestinationInfoMarshaller.cs 87 src/OpenWire/V8/DiscoveryEventMarshaller.cs 53 src/OpenWire/V8/ExceptionResponseMarshaller.cs 48 src/OpenWire/V8/FlushCommandMarshaller.cs 38 src/OpenWire/V8/IntegerResponseMarshaller.cs 46 src/OpenWire/V8/JournalQueueAckMarshaller.cs 53 src/OpenWire/V8/JournalTopicAckMarshaller.cs 73 src/OpenWire/V8/JournalTraceMarshaller.cs 48 src/OpenWire/V8/JournalTransactionMarshaller.cs 57 src/OpenWire/V8/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V8/LastPartialCommandMarshaller.cs 38 src/OpenWire/V8/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V8/MarshallerFactory.cs 66 src/OpenWire/V8/MessageAckMarshaller.cs 81 src/OpenWire/V8/MessageDispatchMarshaller.cs 62 src/OpenWire/V8/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V8/MessageIdMarshaller.cs 58 src/OpenWire/V8/MessageMarshaller.cs 233 src/OpenWire/V8/MessagePullMarshaller.cs 68 src/OpenWire/V8/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V8/PartialCommandMarshaller.cs 60 src/OpenWire/V8/ProducerAckMarshaller.cs 52 src/OpenWire/V8/ProducerIdMarshaller.cs 58 src/OpenWire/V8/ProducerInfoMarshaller.cs 87 src/OpenWire/V8/RemoveInfoMarshaller.cs 53 src/OpenWire/V8/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V8/ReplayCommandMarshaller.cs 50 src/OpenWire/V8/ResponseMarshaller.cs 46 src/OpenWire/V8/SessionIdMarshaller.cs 53 src/OpenWire/V8/SessionInfoMarshaller.cs 48 src/OpenWire/V8/ShutdownInfoMarshaller.cs 38 src/OpenWire/V8/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V8/TransactionIdMarshaller.cs 30 src/OpenWire/V8/TransactionInfoMarshaller.cs 57 src/OpenWire/V8/WireFormatInfoMarshaller.cs 72 src/OpenWire/V8/XATransactionIdMarshaller.cs 73 src/OpenWire/V9/ActiveMQBlobMessageMarshaller.cs 58 src/OpenWire/V9/ActiveMQBytesMessageMarshaller.cs 38 src/OpenWire/V9/ActiveMQDestinationMarshaller.cs 40 src/OpenWire/V9/ActiveMQMapMessageMarshaller.cs 38 src/OpenWire/V9/ActiveMQMessageMarshaller.cs 51 src/OpenWire/V9/ActiveMQObjectMessageMarshaller.cs 38 src/OpenWire/V9/ActiveMQQueueMarshaller.cs 38 src/OpenWire/V9/ActiveMQStreamMessageMarshaller.cs 38 src/OpenWire/V9/ActiveMQTempDestinationMarshaller.cs 30 src/OpenWire/V9/ActiveMQTempQueueMarshaller.cs 38 src/OpenWire/V9/ActiveMQTempTopicMarshaller.cs 38 src/OpenWire/V9/ActiveMQTextMessageMarshaller.cs 38 src/OpenWire/V9/ActiveMQTopicMarshaller.cs 38 src/OpenWire/V9/BaseCommandMarshaller.cs 44 src/OpenWire/V9/BrokerIdMarshaller.cs 48 src/OpenWire/V9/BrokerInfoMarshaller.cs 123 src/OpenWire/V9/ConnectionControlMarshaller.cs 96 src/OpenWire/V9/ConnectionErrorMarshaller.cs 53 src/OpenWire/V9/ConnectionIdMarshaller.cs 48 src/OpenWire/V9/ConnectionInfoMarshaller.cs 118 src/OpenWire/V9/ConsumerControlMarshaller.cs 77 src/OpenWire/V9/ConsumerIdMarshaller.cs 58 src/OpenWire/V9/ConsumerInfoMarshaller.cs 170 src/OpenWire/V9/ControlCommandMarshaller.cs 48 src/OpenWire/V9/DataArrayResponseMarshaller.cs 68 src/OpenWire/V9/DataResponseMarshaller.cs 48 src/OpenWire/V9/DestinationInfoMarshaller.cs 87 src/OpenWire/V9/DiscoveryEventMarshaller.cs 53 src/OpenWire/V9/ExceptionResponseMarshaller.cs 48 src/OpenWire/V9/FlushCommandMarshaller.cs 38 src/OpenWire/V9/IntegerResponseMarshaller.cs 46 src/OpenWire/V9/JournalQueueAckMarshaller.cs 53 src/OpenWire/V9/JournalTopicAckMarshaller.cs 73 src/OpenWire/V9/JournalTraceMarshaller.cs 48 src/OpenWire/V9/JournalTransactionMarshaller.cs 57 src/OpenWire/V9/KeepAliveInfoMarshaller.cs 38 src/OpenWire/V9/LastPartialCommandMarshaller.cs 38 src/OpenWire/V9/LocalTransactionIdMarshaller.cs 53 src/OpenWire/V9/MarshallerFactory.cs 66 src/OpenWire/V9/MessageAckMarshaller.cs 81 src/OpenWire/V9/MessageDispatchMarshaller.cs 62 src/OpenWire/V9/MessageDispatchNotificationMarshaller.cs 63 src/OpenWire/V9/MessageIdMarshaller.cs 58 src/OpenWire/V9/MessageMarshaller.cs 233 src/OpenWire/V9/MessagePullMarshaller.cs 68 src/OpenWire/V9/NetworkBridgeFilterMarshaller.cs 48 src/OpenWire/V9/PartialCommandMarshaller.cs 60 src/OpenWire/V9/ProducerAckMarshaller.cs 52 src/OpenWire/V9/ProducerIdMarshaller.cs 58 src/OpenWire/V9/ProducerInfoMarshaller.cs 87 src/OpenWire/V9/RemoveInfoMarshaller.cs 53 src/OpenWire/V9/RemoveSubscriptionInfoMarshaller.cs 58 src/OpenWire/V9/ReplayCommandMarshaller.cs 50 src/OpenWire/V9/ResponseMarshaller.cs 46 src/OpenWire/V9/SessionIdMarshaller.cs 53 src/OpenWire/V9/SessionInfoMarshaller.cs 48 src/OpenWire/V9/ShutdownInfoMarshaller.cs 38 src/OpenWire/V9/SubscriptionInfoMarshaller.cs 68 src/OpenWire/V9/TransactionIdMarshaller.cs 30 src/OpenWire/V9/TransactionInfoMarshaller.cs 57 src/OpenWire/V9/WireFormatInfoMarshaller.cs 72 src/OpenWire/V9/XATransactionIdMarshaller.cs 73 src/PrefetchPolicy.cs 68 src/QueueBrowser.cs 285 src/RequestTimedOutException.cs 25 src/Session.cs 1043 src/SessionExecutor.cs 180 src/State/CommandVisitorAdapter.cs 151 src/State/ConnectionState.cs 174 src/State/ConnectionStateTracker.cs 682 src/State/ConsumerState.cs 21 src/State/ICommandVisitor.cs 43 src/State/ProducerState.cs 27 src/State/ResponseHandler.cs 11 src/State/SessionState.cs 122 src/State/SynchronizedObjects.cs 197 src/State/Tracked.cs 24 src/State/TransactionState.cs 77 src/Threads/CompositeTask.cs 7 src/Threads/CompositeTaskRunner.cs 160 src/Threads/DedicatedTaskRunner.cs 126 src/Threads/DefaultThreadPools.cs 14 src/Threads/PooledTaskRunner.cs 140 src/Threads/Scheduler.cs 112 src/Threads/Task.cs 7 src/Threads/TaskRunner.cs 11 src/Threads/TaskRunnerFactory.cs 34 src/Threads/ThreadPoolExecutor.cs 146 src/Threads/TimerEx.cs 585 src/Threads/TimerTask.cs 69 src/TransactionContext.cs 211 src/Transactions/IRecoveryLogger.cs 17 src/Transactions/IRecoveryLoggerFactory.cs 8 src/Transactions/RecoveryFileLogger.cs 218 src/Transactions/RecoveryFileLoggerFactory.cs 12 src/Transactions/RecoveryLoggerFactoryAttribute.cs 11 src/Transport/ActiveMQTransportFactoryAttribute.cs 11 src/Transport/Discovery/AbstractDiscoveryAgent.cs 373 src/Transport/Discovery/ActiveMQDiscoveryAgentFactoryAttribute.cs 11 src/Transport/Discovery/DiscoveredServiceData.cs 48 src/Transport/Discovery/DiscoveryAgentFactory.cs 91 src/Transport/Discovery/DiscoveryTransport.cs 146 src/Transport/Discovery/DiscoveryTransportFactory.cs 27 src/Transport/Discovery/IDiscoveryAgent.cs 22 src/Transport/Discovery/IDiscoveryAgentFactory.cs 8 src/Transport/Discovery/Multicast/MulticastDiscoveryAgent.cs 262 src/Transport/Discovery/Multicast/MulticastDiscoveryAgentFactory.cs 26 src/Transport/Discovery/http/HttpDiscoveryAgent.cs 158 src/Transport/Discovery/http/HttpDiscoveryAgentFactory.cs 26 src/Transport/Failover/BackupTransport.cs 80 src/Transport/Failover/FailoverTransport.cs 1487 src/Transport/Failover/FailoverTransportFactory.cs 46 src/Transport/FutureResponse.cs 15 src/Transport/ICompositeTransport.cs 9 src/Transport/ITransport.cs 77 src/Transport/ITransportFactory.cs 10 src/Transport/IWireFormat.cs 19 src/Transport/InactivityMonitor.cs 377 src/Transport/LoggingTransport.cs 25 src/Transport/Mock/IResponseBuilder.cs 10 src/Transport/Mock/MockTransport.cs 355 src/Transport/Mock/MockTransportFactory.cs 96 src/Transport/Mock/OpenWireResponseBuilder.cs 31 src/Transport/MutexTransport.cs 74 src/Transport/ResponseCorrelator.cs 138 src/Transport/Tcp/SslContext.cs 35 src/Transport/Tcp/SslTransport.cs 260 src/Transport/Tcp/SslTransportFactory.cs 108 src/Transport/Tcp/TcpTransport.cs 330 src/Transport/Tcp/TcpTransportFactory.cs 347 src/Transport/TransportFactory.cs 105 src/Transport/TransportFilter.cs 184 src/Transport/WireFormatNegotiator.cs 78 src/Util/ActiveMQMessageAudit.cs 132 src/Util/ActiveMQMessageTransformation.cs 112 src/Util/AdvisorySupport.cs 522 src/Util/AtomicExtensions.cs 25 src/Util/BitArray.cs 76 src/Util/BitArrayBin.cs 139 src/Util/ConnectionAudit.cs 111 src/Util/FactoryAttribute.cs 23 src/Util/FactoryFinder.cs 86 src/Util/FifoMessageDispatchChannel.cs 187 src/Util/ISuspendable.cs 9 src/Util/IdGenerator.cs 108 src/Util/IntrospectionSupport.cs 116 src/Util/LRUCache.cs 115 src/Util/MemoryUsage.cs 111 src/Util/MessageDispatchChannel.cs 42 src/Util/ServiceStopper.cs 38 src/Util/SimplePriorityMessageDispatchChannel.cs 242 src/Util/Synchronization/NmsSynchronizationMonitor.cs 223 src/Util/Synchronization/TaskExtensions.cs 41 src/Util/Synchronization/TaskSynchronizationSettings.cs 8 src/sandbox/alternative-threading/CountDownLatch2.cs 72 src/sandbox/alternative-threading/Dispatcher.cs 132 src/sandbox/alternative-threading/DispatchingThread.cs 99 src/sandbox/alternative-threading/EventSemaphore.cs 29 src/sandbox/alternative-threading/FutureResponse.cs 49