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