| /** |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.apache.activemq.openwire.v4; |
| |
| import java.io.DataInputStream; |
| import java.io.DataOutputStream; |
| import java.io.IOException; |
| |
| import org.apache.activemq.openwire.*; |
| import org.apache.activemq.command.*; |
| |
| |
| /** |
| * Test case for the OpenWire marshalling for Message |
| * |
| * |
| * NOTE!: This file is auto generated - do not modify! |
| * if you need to make a change, please see the modify the groovy scripts in the |
| * under src/gram/script and then use maven openwire:generate to regenerate |
| * this file. |
| * |
| * |
| */ |
| public abstract class MessageTestSupport extends BaseCommandTestSupport { |
| |
| |
| protected void populateObject(Object object) throws Exception { |
| super.populateObject(object); |
| Message info = (Message) object; |
| |
| info.setProducerId(createProducerId("ProducerId:1")); |
| info.setDestination(createActiveMQDestination("Destination:2")); |
| info.setTransactionId(createTransactionId("TransactionId:3")); |
| info.setOriginalDestination(createActiveMQDestination("OriginalDestination:4")); |
| info.setMessageId(createMessageId("MessageId:5")); |
| info.setOriginalTransactionId(createTransactionId("OriginalTransactionId:6")); |
| info.setGroupID("GroupID:7"); |
| info.setGroupSequence(1); |
| info.setCorrelationId("CorrelationId:8"); |
| info.setPersistent(true); |
| info.setExpiration(1); |
| info.setPriority((byte) 1); |
| info.setReplyTo(createActiveMQDestination("ReplyTo:9")); |
| info.setTimestamp(2); |
| info.setType("Type:10"); |
| { |
| byte data[] = "Content:11".getBytes(); |
| info.setContent(new org.apache.activemq.util.ByteSequence(data,0,data.length)); |
| } |
| { |
| byte data[] = "MarshalledProperties:12".getBytes(); |
| info.setMarshalledProperties(new org.apache.activemq.util.ByteSequence(data,0,data.length)); |
| } |
| info.setDataStructure(createDataStructure("DataStructure:13")); |
| info.setTargetConsumerId(createConsumerId("TargetConsumerId:14")); |
| info.setCompressed(false); |
| info.setRedeliveryCounter(2); |
| { |
| BrokerId value[] = new BrokerId[2]; |
| for( int i=0; i < 2; i++ ) { |
| value[i] = createBrokerId("BrokerPath:15"); |
| } |
| info.setBrokerPath(value); |
| } |
| info.setArrival(3); |
| info.setUserID("UserID:16"); |
| info.setRecievedByDFBridge(true); |
| info.setDroppable(false); |
| { |
| BrokerId value[] = new BrokerId[2]; |
| for( int i=0; i < 2; i++ ) { |
| value[i] = createBrokerId("Cluster:17"); |
| } |
| info.setCluster(value); |
| } |
| info.setBrokerInTime(4); |
| info.setBrokerOutTime(5); |
| } |
| } |