Path	Lines of Code
openwire-core/src/main/java/org/apache/activemq/openwire/buffer/Buffer.java	167
openwire-core/src/main/java/org/apache/activemq/openwire/buffer/DataByteArrayInputStream.java	252
openwire-core/src/main/java/org/apache/activemq/openwire/buffer/DataByteArrayOutputStream.java	200
openwire-core/src/main/java/org/apache/activemq/openwire/buffer/UTF8Buffer.java	63
openwire-core/src/main/java/org/apache/activemq/openwire/codec/BaseDataStreamMarshaller.java	524
openwire-core/src/main/java/org/apache/activemq/openwire/codec/BooleanStream.java	91
openwire-core/src/main/java/org/apache/activemq/openwire/codec/DataStreamMarshaller.java	14
openwire-core/src/main/java/org/apache/activemq/openwire/codec/OpenWireConstants.java	18
openwire-core/src/main/java/org/apache/activemq/openwire/codec/OpenWireFormat.java	476
openwire-core/src/main/java/org/apache/activemq/openwire/codec/OpenWireFormatFactory.java	107
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/BaseCommandMarshaller.java	38
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/BrokerIdMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/BrokerInfoMarshaller.java	168
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConnectionControlMarshaller.java	125
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConnectionErrorMarshaller.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConnectionIdMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConnectionInfoMarshaller.java	153
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConsumerControlMarshaller.java	114
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConsumerIdMarshaller.java	50
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConsumerInfoMarshaller.java	188
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ControlCommandMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/DataArrayResponseMarshaller.java	58
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/DataResponseMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/DestinationInfoMarshaller.java	77
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/DiscoveryEventMarshaller.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ExceptionResponseMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/FlushCommandMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/IntegerResponseMarshaller.java	39
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/JournalQueueAckMarshaller.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/JournalTopicAckMarshaller.java	65
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/JournalTraceMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/JournalTransactionMarshaller.java	49
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/KeepAliveInfoMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/LastPartialCommandMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/LocalTransactionIdMarshaller.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MarshallerFactory.java	70
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageAckMarshaller.java	88
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageDispatchMarshaller.java	54
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageDispatchNotificationMarshaller.java	55
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageIdMarshaller.java	70
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageMarshaller.java	275
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessagePullMarshaller.java	85
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/NetworkBridgeFilterMarshaller.java	73
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireBlobMessageMarshaller.java	85
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireBytesMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireDestinationMarshaller.java	34
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireMapMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireObjectMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireQueueMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireStreamMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireTempDestinationMarshaller.java	24
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireTempQueueMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireTempTopicMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireTextMessageMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/OpenWireTopicMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/PartialCommandMarshaller.java	44
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ProducerAckMarshaller.java	69
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ProducerIdMarshaller.java	50
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ProducerInfoMarshaller.java	102
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/RemoveInfoMarshaller.java	60
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/RemoveSubscriptionInfoMarshaller.java	50
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ReplayCommandMarshaller.java	43
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ResponseMarshaller.java	39
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/SessionIdMarshaller.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/SessionInfoMarshaller.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ShutdownInfoMarshaller.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/SubscriptionInfoMarshaller.java	90
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/TransactionIdMarshaller.java	24
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/TransactionInfoMarshaller.java	49
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/WireFormatInfoMarshaller.java	57
openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/XATransactionIdMarshaller.java	49
openwire-core/src/main/java/org/apache/activemq/openwire/commands/BaseCommand.java	90
openwire-core/src/main/java/org/apache/activemq/openwire/commands/BrokerId.java	47
openwire-core/src/main/java/org/apache/activemq/openwire/commands/BrokerInfo.java	135
openwire-core/src/main/java/org/apache/activemq/openwire/commands/Command.java	21
openwire-core/src/main/java/org/apache/activemq/openwire/commands/CommandTypes.java	73
openwire-core/src/main/java/org/apache/activemq/openwire/commands/CommandVisitor.java	37
openwire-core/src/main/java/org/apache/activemq/openwire/commands/CommandVisitorAdapter.java	139
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConnectionControl.java	91
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConnectionError.java	31
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConnectionId.java	63
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConnectionInfo.java	139
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConsumerControl.java	71
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConsumerId.java	99
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ConsumerInfo.java	270
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ControlCommand.java	23
openwire-core/src/main/java/org/apache/activemq/openwire/commands/DataArrayResponse.java	24
openwire-core/src/main/java/org/apache/activemq/openwire/commands/DataResponse.java	24
openwire-core/src/main/java/org/apache/activemq/openwire/commands/DataStructure.java	5
openwire-core/src/main/java/org/apache/activemq/openwire/commands/DestinationInfo.java	85
openwire-core/src/main/java/org/apache/activemq/openwire/commands/DiscoveryEvent.java	40
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ExceptionResponse.java	28
openwire-core/src/main/java/org/apache/activemq/openwire/commands/FlushCommand.java	15
openwire-core/src/main/java/org/apache/activemq/openwire/commands/IntegerResponse.java	24
openwire-core/src/main/java/org/apache/activemq/openwire/commands/JournalQueueAck.java	35
openwire-core/src/main/java/org/apache/activemq/openwire/commands/JournalTopicAck.java	67
openwire-core/src/main/java/org/apache/activemq/openwire/commands/JournalTrace.java	32
openwire-core/src/main/java/org/apache/activemq/openwire/commands/JournalTransaction.java	55
openwire-core/src/main/java/org/apache/activemq/openwire/commands/KeepAliveInfo.java	54
openwire-core/src/main/java/org/apache/activemq/openwire/commands/LastPartialCommand.java	16
openwire-core/src/main/java/org/apache/activemq/openwire/commands/LocalTransactionId.java	83
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MarshallAware.java	9
openwire-core/src/main/java/org/apache/activemq/openwire/commands/Message.java	491
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MessageAck.java	146
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MessageDispatch.java	51
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MessageDispatchNotification.java	51
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MessageId.java	139
openwire-core/src/main/java/org/apache/activemq/openwire/commands/MessagePull.java	72
openwire-core/src/main/java/org/apache/activemq/openwire/commands/NetworkBridgeFilter.java	56
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireBlobMessage.java	82
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireBytesMessage.java	108
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireDestination.java	277
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireMapMessage.java	167
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireMessage.java	228
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireObjectMessage.java	129
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireQueue.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireStreamMessage.java	141
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireTempDestination.java	52
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireTempQueue.java	33
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireTempTopic.java	33
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireTextMessage.java	134
openwire-core/src/main/java/org/apache/activemq/openwire/commands/OpenWireTopic.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/commands/PartialCommand.java	106
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ProducerAck.java	42
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ProducerId.java	105
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ProducerInfo.java	82
openwire-core/src/main/java/org/apache/activemq/openwire/commands/RemoveInfo.java	60
openwire-core/src/main/java/org/apache/activemq/openwire/commands/RemoveSubscriptionInfo.java	45
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ReplayCommand.java	62
openwire-core/src/main/java/org/apache/activemq/openwire/commands/Response.java	30
openwire-core/src/main/java/org/apache/activemq/openwire/commands/SessionId.java	87
openwire-core/src/main/java/org/apache/activemq/openwire/commands/SessionInfo.java	41
openwire-core/src/main/java/org/apache/activemq/openwire/commands/ShutdownInfo.java	18
openwire-core/src/main/java/org/apache/activemq/openwire/commands/SubscriptionInfo.java	100
openwire-core/src/main/java/org/apache/activemq/openwire/commands/TransactionId.java	12
openwire-core/src/main/java/org/apache/activemq/openwire/commands/TransactionInfo.java	74
openwire-core/src/main/java/org/apache/activemq/openwire/commands/WireFormatInfo.java	278
openwire-core/src/main/java/org/apache/activemq/openwire/commands/XATransactionId.java	205
openwire-core/src/main/java/org/apache/activemq/openwire/commands/package.html	8
openwire-core/src/main/java/org/apache/activemq/openwire/utils/HexSupport.java	56
openwire-core/src/main/java/org/apache/activemq/openwire/utils/IOExceptionSupport.java	25
openwire-core/src/main/java/org/apache/activemq/openwire/utils/ObjectMessageInputStream.java	105
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireConnection.java	61
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireConsumer.java	36
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireIdGenerator.java	163
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireMarshallingSupport.java	365
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireProducer.java	43
openwire-core/src/main/java/org/apache/activemq/openwire/utils/OpenWireSession.java	48