activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v6/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v4/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v5/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v10/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v8/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v11/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v9/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v7/MarshallerFactory.java [35:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MarshallerFactory { /** * Creates a Map of command type -> Marshallers */ static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static { add(new ActiveMQBlobMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQMapMessageMarshaller()); add(new ActiveMQMessageMarshaller()); add(new ActiveMQObjectMessageMarshaller()); add(new ActiveMQQueueMarshaller()); add(new ActiveMQStreamMessageMarshaller()); add(new ActiveMQTempQueueMarshaller()); add(new ActiveMQTempTopicMarshaller()); add(new ActiveMQTextMessageMarshaller()); add(new ActiveMQTopicMarshaller()); add(new BrokerIdMarshaller()); add(new BrokerInfoMarshaller()); add(new ConnectionControlMarshaller()); add(new ConnectionErrorMarshaller()); add(new ConnectionIdMarshaller()); add(new ConnectionInfoMarshaller()); add(new ConsumerControlMarshaller()); add(new ConsumerIdMarshaller()); add(new ConsumerInfoMarshaller()); add(new ControlCommandMarshaller()); add(new DataArrayResponseMarshaller()); add(new DataResponseMarshaller()); add(new DestinationInfoMarshaller()); add(new DiscoveryEventMarshaller()); add(new ExceptionResponseMarshaller()); add(new FlushCommandMarshaller()); add(new IntegerResponseMarshaller()); add(new JournalQueueAckMarshaller()); add(new JournalTopicAckMarshaller()); add(new JournalTraceMarshaller()); add(new JournalTransactionMarshaller()); add(new KeepAliveInfoMarshaller()); add(new LastPartialCommandMarshaller()); add(new LocalTransactionIdMarshaller()); add(new MessageAckMarshaller()); add(new MessageDispatchMarshaller()); add(new MessageDispatchNotificationMarshaller()); add(new MessageIdMarshaller()); add(new MessagePullMarshaller()); add(new NetworkBridgeFilterMarshaller()); add(new PartialCommandMarshaller()); add(new ProducerAckMarshaller()); add(new ProducerIdMarshaller()); add(new ProducerInfoMarshaller()); add(new RemoveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller()); add(new ReplayCommandMarshaller()); add(new ResponseMarshaller()); add(new SessionIdMarshaller()); add(new SessionInfoMarshaller()); add(new ShutdownInfoMarshaller()); add(new SubscriptionInfoMarshaller()); add(new TransactionInfoMarshaller()); add(new WireFormatInfoMarshaller()); add(new XATransactionIdMarshaller()); } static private void add(DataStreamMarshaller dsm) { marshaller[dsm.getDataStructureType()] = dsm; } static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) { return marshaller; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -