001 /**
002 *
003 * Licensed to the Apache Software Foundation (ASF) under one or more
004 * contributor license agreements. See the NOTICE file distributed with
005 * this work for additional information regarding copyright ownership.
006 * The ASF licenses this file to You under the Apache License, Version 2.0
007 * (the "License"); you may not use this file except in compliance with
008 * the License. You may obtain a copy of the License at
009 *
010 * http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing, software
013 * distributed under the License is distributed on an "AS IS" BASIS,
014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018
019 package org.apache.activemq.openwire.v7;
020
021 import org.apache.activemq.openwire.DataStreamMarshaller;
022 import org.apache.activemq.openwire.OpenWireFormat;
023
024 /**
025 * MarshallerFactory for Open Wire Format.
026 *
027 *
028 * NOTE!: This file is auto generated - do not modify!
029 * if you need to make a change, please see the modify the groovy scripts in the
030 * under src/gram/script and then use maven openwire:generate to regenerate
031 * this file.
032 *
033 *
034 */
035 public class MarshallerFactory {
036
037 /**
038 * Creates a Map of command type -> Marshallers
039 */
040 static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256];
041 static {
042
043 add(new ActiveMQBlobMessageMarshaller());
044 add(new ActiveMQBytesMessageMarshaller());
045 add(new ActiveMQMapMessageMarshaller());
046 add(new ActiveMQMessageMarshaller());
047 add(new ActiveMQObjectMessageMarshaller());
048 add(new ActiveMQQueueMarshaller());
049 add(new ActiveMQStreamMessageMarshaller());
050 add(new ActiveMQTempQueueMarshaller());
051 add(new ActiveMQTempTopicMarshaller());
052 add(new ActiveMQTextMessageMarshaller());
053 add(new ActiveMQTopicMarshaller());
054 add(new BrokerIdMarshaller());
055 add(new BrokerInfoMarshaller());
056 add(new ConnectionControlMarshaller());
057 add(new ConnectionErrorMarshaller());
058 add(new ConnectionIdMarshaller());
059 add(new ConnectionInfoMarshaller());
060 add(new ConsumerControlMarshaller());
061 add(new ConsumerIdMarshaller());
062 add(new ConsumerInfoMarshaller());
063 add(new ControlCommandMarshaller());
064 add(new DataArrayResponseMarshaller());
065 add(new DataResponseMarshaller());
066 add(new DestinationInfoMarshaller());
067 add(new DiscoveryEventMarshaller());
068 add(new ExceptionResponseMarshaller());
069 add(new FlushCommandMarshaller());
070 add(new IntegerResponseMarshaller());
071 add(new JournalQueueAckMarshaller());
072 add(new JournalTopicAckMarshaller());
073 add(new JournalTraceMarshaller());
074 add(new JournalTransactionMarshaller());
075 add(new KeepAliveInfoMarshaller());
076 add(new LastPartialCommandMarshaller());
077 add(new LocalTransactionIdMarshaller());
078 add(new MessageAckMarshaller());
079 add(new MessageDispatchMarshaller());
080 add(new MessageDispatchNotificationMarshaller());
081 add(new MessageIdMarshaller());
082 add(new MessagePullMarshaller());
083 add(new NetworkBridgeFilterMarshaller());
084 add(new PartialCommandMarshaller());
085 add(new ProducerAckMarshaller());
086 add(new ProducerIdMarshaller());
087 add(new ProducerInfoMarshaller());
088 add(new RemoveInfoMarshaller());
089 add(new RemoveSubscriptionInfoMarshaller());
090 add(new ReplayCommandMarshaller());
091 add(new ResponseMarshaller());
092 add(new SessionIdMarshaller());
093 add(new SessionInfoMarshaller());
094 add(new ShutdownInfoMarshaller());
095 add(new SubscriptionInfoMarshaller());
096 add(new TransactionInfoMarshaller());
097 add(new WireFormatInfoMarshaller());
098 add(new XATransactionIdMarshaller());
099
100 }
101
102 static private void add(DataStreamMarshaller dsm) {
103 marshaller[dsm.getDataStructureType()] = dsm;
104 }
105
106 static public DataStreamMarshaller[] createMarshallerMap(OpenWireFormat wireFormat) {
107 return marshaller;
108 }
109 }