Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Modified the BrokerInfo so that the redelivery policy is now purely configured on the client side. Also the connection's transport 

is not started until the connection if fully configured now.



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@360140 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2005-12-30 18:48:31 +00:00
parent 1f3f80cf77
commit 90e21b4e8f
59 changed files with 3162 additions and 3086 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -102,7 +102,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
// Connection state variables // Connection state variables
private final ConnectionInfo info; private final ConnectionInfo info;
private ExceptionListener exceptionListener; private ExceptionListener exceptionListener;
private String resourceManagerId;
private boolean clientIDSet; private boolean clientIDSet;
private boolean isConnectionInfoSentToBroker; private boolean isConnectionInfoSentToBroker;
private boolean userSpecifiedClientID; private boolean userSpecifiedClientID;
@ -145,6 +144,8 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
private AdvisoryConsumer advisoryConsumer; private AdvisoryConsumer advisoryConsumer;
private final CountDownLatch brokerInfoReceived = new CountDownLatch(1); private final CountDownLatch brokerInfoReceived = new CountDownLatch(1);
private BrokerInfo brokerInfo;
/** /**
@ -155,21 +156,26 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* @param password * @param password
* @throws Exception * @throws Exception
*/ */
protected ActiveMQConnection(Transport transport, String userName, String password, JMSStatsImpl factoryStats) protected ActiveMQConnection(Transport transport, JMSStatsImpl factoryStats)
throws Exception { throws Exception {
this.transport = transport;
this.info = new ConnectionInfo(new ConnectionId(connectionIdGenerator.generateId())); this.info = new ConnectionInfo(new ConnectionId(connectionIdGenerator.generateId()));
this.info.setUserName(userName);
this.info.setPassword(password);
this.connectionSessionId = new SessionId(info.getConnectionId(), -1); this.connectionSessionId = new SessionId(info.getConnectionId(), -1);
this.factoryStats = factoryStats; this.transport = transport;
this.factoryStats.addConnection(this);
this.stats = new JMSConnectionStatsImpl(sessions, this instanceof XAConnection);
this.transport.setTransportListener(this); this.transport.setTransportListener(this);
transport.start(); this.stats = new JMSConnectionStatsImpl(sessions, this instanceof XAConnection);
this.factoryStats = factoryStats;
this.factoryStats.addConnection(this);
}
protected void setUserName(String userName) {
this.info.setUserName(userName);
}
protected void setPassword(String password) {
this.info.setPassword(password);
} }
/** /**
@ -1203,9 +1209,9 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
*/ */
public String getResourceManagerId() throws JMSException { public String getResourceManagerId() throws JMSException {
waitForBrokerInfo(); waitForBrokerInfo();
if( resourceManagerId==null ) if( brokerInfo==null )
throw new JMSException("Resource manager id could not be determined."); throw new JMSException("Connection failed before Broker info was received.");
return resourceManagerId; return brokerInfo.getBrokerId().getBrokerId();
} }
/** /**
@ -1213,7 +1219,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
* @throws JMSException * @throws JMSException
*/ */
public RedeliveryPolicy getRedeliveryPolicy() throws JMSException { public RedeliveryPolicy getRedeliveryPolicy() throws JMSException {
waitForBrokerInfo();
return redeliveryPolicy; return redeliveryPolicy;
} }
@ -1267,15 +1272,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
dispatcher.dispatch(md); dispatcher.dispatch(md);
} }
} else if ( command.isBrokerInfo() ) { } else if ( command.isBrokerInfo() ) {
BrokerInfo brokerInfo = (BrokerInfo)command; this.brokerInfo = (BrokerInfo)command;
resourceManagerId = brokerInfo.getBrokerId().getBrokerId();
if( redeliveryPolicy == null ) {
if( brokerInfo.getRedeliveryPolicy()!=null ) {
redeliveryPolicy = brokerInfo.getRedeliveryPolicy();
} else {
redeliveryPolicy = new RedeliveryPolicy();
}
}
brokerInfoReceived.countDown(); brokerInfoReceived.countDown();
} }
else if (command instanceof ControlCommand) { else if (command instanceof ControlCommand) {

14
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
View File

@ -67,7 +67,7 @@ public class ActiveMQConnectionFactory implements ConnectionFactory, QueueConnec
// optimization flags // optimization flags
private ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy(); private ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy();
private RedeliveryPolicy redeliveryPolicy; private RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
private boolean disableTimeStampsByDefault = false; private boolean disableTimeStampsByDefault = false;
private boolean onSendPrepareMessageBody = true; private boolean onSendPrepareMessageBody = true;
@ -198,8 +198,10 @@ public class ActiveMQConnectionFactory implements ConnectionFactory, QueueConnec
Transport transport; Transport transport;
try { try {
transport = TransportFactory.connect(brokerURL,DEFAULT_CONNECTION_EXECUTOR); transport = TransportFactory.connect(brokerURL,DEFAULT_CONNECTION_EXECUTOR);
ActiveMQConnection connection = new ActiveMQConnection(transport, userName, password, factoryStats); ActiveMQConnection connection = new ActiveMQConnection(transport, factoryStats);
connection.setUserName(userName);
connection.setPassword(password);
connection.setPrefetchPolicy(getPrefetchPolicy()); connection.setPrefetchPolicy(getPrefetchPolicy());
connection.setDisableTimeStampsByDefault(isDisableTimeStampsByDefault()); connection.setDisableTimeStampsByDefault(isDisableTimeStampsByDefault());
connection.setOnSendPrepareMessageBody(isOnSendPrepareMessageBody()); connection.setOnSendPrepareMessageBody(isOnSendPrepareMessageBody());
@ -210,13 +212,13 @@ public class ActiveMQConnectionFactory implements ConnectionFactory, QueueConnec
connection.setAsyncDispatch(isAsyncDispatch()); connection.setAsyncDispatch(isAsyncDispatch());
connection.setUseAsyncSend(isUseAsyncSend()); connection.setUseAsyncSend(isUseAsyncSend());
connection.setUseRetroactiveConsumer(isUseRetroactiveConsumer()); connection.setUseRetroactiveConsumer(isUseRetroactiveConsumer());
if (getRedeliveryPolicy() != null) { connection.setRedeliveryPolicy(getRedeliveryPolicy());
connection.setRedeliveryPolicy(getRedeliveryPolicy());
} transport.start();
if( clientID !=null ) if( clientID !=null )
connection.setClientID(clientID); connection.setClientID(clientID);
return connection; return connection;
} }
catch (JMSException e) { catch (JMSException e) {

4
activemq-core/src/main/java/org/apache/activemq/ActiveMQXAConnection.java
View File

@ -56,8 +56,8 @@ public class ActiveMQXAConnection extends ActiveMQConnection implements XATopicC
* @param factoryStats * @param factoryStats
* @throws Exception * @throws Exception
*/ */
public ActiveMQXAConnection(Transport transport, String theUserName, String thePassword, JMSStatsImpl factoryStats) throws Exception { protected ActiveMQXAConnection(Transport transport, JMSStatsImpl factoryStats) throws Exception {
super(transport, theUserName, thePassword, factoryStats); super(transport, factoryStats);
} }
public XASession createXASession() throws JMSException { public XASession createXASession() throws JMSException {

42
activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
View File

@ -18,7 +18,6 @@ package org.apache.activemq.broker.jmx;
import org.apache.activemq.broker.Connector; import org.apache.activemq.broker.Connector;
import org.apache.activemq.command.BrokerInfo; import org.apache.activemq.command.BrokerInfo;
import org.apache.activemq.command.RedeliveryPolicy;
public class ConnectorView implements ConnectorViewMBean { public class ConnectorView implements ConnectorViewMBean {
@ -47,47 +46,6 @@ public class ConnectorView implements ConnectorViewMBean {
public BrokerInfo getBrokerInfo() { public BrokerInfo getBrokerInfo() {
return connector.getBrokerInfo(); return connector.getBrokerInfo();
} }
public short getBackOffMultiplier() {
return getRedeliveryPolicy().getBackOffMultiplier();
}
public long getInitialRedeliveryDelay() {
return getRedeliveryPolicy().getInitialRedeliveryDelay();
}
public int getMaximumRedeliveries() {
return getRedeliveryPolicy().getMaximumRedeliveries();
}
public boolean isUseExponentialBackOff() {
return getRedeliveryPolicy().isUseExponentialBackOff();
}
public void setBackOffMultiplier(short backOffMultiplier) {
getRedeliveryPolicy().setBackOffMultiplier(backOffMultiplier);
}
public void setInitialRedeliveryDelay(long initialRedeliveryDelay) {
getRedeliveryPolicy().setInitialRedeliveryDelay(initialRedeliveryDelay);
}
public void setMaximumRedeliveries(int maximumRedeliveries) {
getRedeliveryPolicy().setMaximumRedeliveries(maximumRedeliveries);
}
public void setUseExponentialBackOff(boolean useExponentialBackOff) {
getRedeliveryPolicy().setUseExponentialBackOff(useExponentialBackOff);
}
public RedeliveryPolicy getRedeliveryPolicy() {
RedeliveryPolicy redeliveryPolicy = getBrokerInfo().getRedeliveryPolicy();
if (redeliveryPolicy == null) {
redeliveryPolicy = new RedeliveryPolicy();
getBrokerInfo().setRedeliveryPolicy(redeliveryPolicy);
}
return redeliveryPolicy;
}
/** /**
* Resets the statistics * Resets the statistics

16
activemq-core/src/main/java/org/apache/activemq/broker/jmx/ConnectorViewMBean.java
View File

@ -19,22 +19,6 @@ package org.apache.activemq.broker.jmx;
import org.apache.activemq.Service; import org.apache.activemq.Service;
public interface ConnectorViewMBean extends Service { public interface ConnectorViewMBean extends Service {
public short getBackOffMultiplier();
public long getInitialRedeliveryDelay();
public int getMaximumRedeliveries();
public boolean isUseExponentialBackOff();
public void setBackOffMultiplier(short backOffMultiplier);
public void setInitialRedeliveryDelay(long initialRedeliveryDelay);
public void setMaximumRedeliveries(int maximumRedeliveries);
public void setUseExponentialBackOff(boolean useExponentialBackOff);
/** /**
* Resets the statistics * Resets the statistics

11
activemq-core/src/main/java/org/apache/activemq/command/BrokerInfo.java
View File

@ -33,7 +33,6 @@ public class BrokerInfo extends BaseCommand {
public static final byte DATA_STRUCTURE_TYPE=CommandTypes.BROKER_INFO; public static final byte DATA_STRUCTURE_TYPE=CommandTypes.BROKER_INFO;
BrokerId brokerId; BrokerId brokerId;
String brokerURL; String brokerURL;
RedeliveryPolicy redeliveryPolicy;
BrokerInfo peerBrokerInfos[]; BrokerInfo peerBrokerInfos[];
String brokerName; String brokerName;
@ -76,16 +75,6 @@ public class BrokerInfo extends BaseCommand {
this.peerBrokerInfos = peerBrokerInfos; this.peerBrokerInfos = peerBrokerInfos;
} }
/**
* @openwire:property version=1
*/
public RedeliveryPolicy getRedeliveryPolicy() {
return redeliveryPolicy;
}
public void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy) {
this.redeliveryPolicy = redeliveryPolicy;
}
/** /**
* @openwire:property version=1 * @openwire:property version=1
*/ */

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQBytesMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQDestinationMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQMapMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQObjectMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQQueueMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQStreamMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempDestinationMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempQueueMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTempTopicMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTextMessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ActiveMQTopicMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/BaseCommandMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/BrokerIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

36
activemq-core/src/main/java/org/apache/activemq/openwire/v1/BrokerInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**
@ -77,7 +80,6 @@ public class BrokerInfoMarshaller extends BaseCommandMarshaller {
info.setPeerBrokerInfos(null); info.setPeerBrokerInfos(null);
} }
info.setRedeliveryPolicy((org.apache.activemq.command.RedeliveryPolicy) unmarsalNestedObject(wireFormat, dataIn, bs));
info.setBrokerName(readString(dataIn, bs)); info.setBrokerName(readString(dataIn, bs));
} }
@ -94,7 +96,6 @@ public class BrokerInfoMarshaller extends BaseCommandMarshaller {
rc += marshal1CachedObject(wireFormat, info.getBrokerId(), bs); rc += marshal1CachedObject(wireFormat, info.getBrokerId(), bs);
rc += writeString(info.getBrokerURL(), bs); rc += writeString(info.getBrokerURL(), bs);
rc += marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), bs); rc += marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), bs);
rc += marshal1NestedObject(wireFormat, info.getRedeliveryPolicy(), bs);
rc += writeString(info.getBrokerName(), bs); rc += writeString(info.getBrokerName(), bs);
return rc+0; return rc+0;
@ -114,7 +115,6 @@ public class BrokerInfoMarshaller extends BaseCommandMarshaller {
marshal2CachedObject(wireFormat, info.getBrokerId(), dataOut, bs); marshal2CachedObject(wireFormat, info.getBrokerId(), dataOut, bs);
writeString(info.getBrokerURL(), dataOut, bs); writeString(info.getBrokerURL(), dataOut, bs);
marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), dataOut, bs); marshalObjectArray(wireFormat, info.getPeerBrokerInfos(), dataOut, bs);
marshal2NestedObject(wireFormat, info.getRedeliveryPolicy(), dataOut, bs);
writeString(info.getBrokerName(), dataOut, bs); writeString(info.getBrokerName(), dataOut, bs);
} }

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConnectionInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ConsumerInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ControlCommandMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/DataArrayResponseMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/DataResponseMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/DestinationInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ExceptionResponseMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/FlushCommandMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/IntegerResponseMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/JournalQueueAckMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/JournalTopicAckMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/JournalTraceMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/JournalTransactionMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/KeepAliveInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/LocalTransactionIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

107
activemq-core/src/main/java/org/apache/activemq/openwire/v1/MarshallerFactory.java
View File

@ -1,19 +1,22 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import org.apache.activemq.openwire.DataStreamMarshaller; import org.apache.activemq.openwire.DataStreamMarshaller;
@ -38,51 +41,51 @@ public class MarshallerFactory {
static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256]; static final private DataStreamMarshaller marshaller[] = new DataStreamMarshaller[256];
static { static {
add(new ActiveMQMessageMarshaller());
add(new MessageIdMarshaller()); add(new MessageIdMarshaller());
add(new ControlCommandMarshaller());
add(new FlushCommandMarshaller());
add(new IntegerResponseMarshaller());
add(new RemoveSubscriptionInfoMarshaller());
add(new SubscriptionInfoMarshaller());
add(new DataArrayResponseMarshaller());
add(new ConnectionIdMarshaller());
add(new BrokerInfoMarshaller()); add(new BrokerInfoMarshaller());
add(new JournalTraceMarshaller()); add(new ActiveMQTempQueueMarshaller());
add(new MessageDispatchMarshaller()); add(new LocalTransactionIdMarshaller());
add(new KeepAliveInfoMarshaller()); add(new RemoveSubscriptionInfoMarshaller());
add(new ActiveMQStreamMessageMarshaller()); add(new IntegerResponseMarshaller());
add(new JournalQueueAckMarshaller()); add(new ActiveMQQueueMarshaller());
add(new ActiveMQTempTopicMarshaller()); add(new DestinationInfoMarshaller());
add(new ProducerInfoMarshaller());
add(new BrokerIdMarshaller());
add(new MessageAckMarshaller());
add(new ActiveMQBytesMessageMarshaller()); add(new ActiveMQBytesMessageMarshaller());
add(new SessionInfoMarshaller());
add(new ActiveMQTextMessageMarshaller());
add(new ActiveMQMapMessageMarshaller());
add(new ShutdownInfoMarshaller()); add(new ShutdownInfoMarshaller());
add(new DataResponseMarshaller()); add(new DataResponseMarshaller());
add(new JournalTopicAckMarshaller());
add(new DestinationInfoMarshaller());
add(new XATransactionIdMarshaller());
add(new ActiveMQObjectMessageMarshaller());
add(new ConsumerIdMarshaller());
add(new SessionIdMarshaller()); add(new SessionIdMarshaller());
add(new ConsumerInfoMarshaller()); add(new DataArrayResponseMarshaller());
add(new ConnectionInfoMarshaller()); add(new JournalQueueAckMarshaller());
add(new ActiveMQTopicMarshaller());
add(new RedeliveryPolicyMarshaller());
add(new ExceptionResponseMarshaller());
add(new JournalTransactionMarshaller());
add(new ProducerIdMarshaller());
add(new ActiveMQQueueMarshaller());
add(new ActiveMQTempQueueMarshaller());
add(new TransactionInfoMarshaller());
add(new ResponseMarshaller());
add(new RemoveInfoMarshaller());
add(new WireFormatInfoMarshaller()); add(new WireFormatInfoMarshaller());
add(new LocalTransactionIdMarshaller()); add(new ResponseMarshaller());
add(new ActiveMQObjectMessageMarshaller());
add(new ConsumerInfoMarshaller());
add(new ConnectionIdMarshaller());
add(new ActiveMQTempTopicMarshaller());
add(new ConnectionInfoMarshaller());
add(new KeepAliveInfoMarshaller());
add(new XATransactionIdMarshaller());
add(new JournalTraceMarshaller());
add(new FlushCommandMarshaller());
add(new RedeliveryPolicyMarshaller());
add(new ConsumerIdMarshaller());
add(new JournalTopicAckMarshaller());
add(new ActiveMQTextMessageMarshaller());
add(new BrokerIdMarshaller());
add(new MessageDispatchMarshaller());
add(new ProducerInfoMarshaller());
add(new SubscriptionInfoMarshaller());
add(new ActiveMQMapMessageMarshaller());
add(new SessionInfoMarshaller());
add(new ActiveMQMessageMarshaller());
add(new TransactionInfoMarshaller());
add(new ActiveMQStreamMessageMarshaller());
add(new MessageAckMarshaller());
add(new ProducerIdMarshaller());
add(new ActiveMQTopicMarshaller());
add(new JournalTransactionMarshaller());
add(new RemoveInfoMarshaller());
add(new ControlCommandMarshaller());
add(new ExceptionResponseMarshaller());
} }

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/MessageAckMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/MessageDispatchMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/MessageIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/MessageMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ProducerIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ProducerInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/RedeliveryPolicyMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/RemoveInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/RemoveSubscriptionInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ResponseMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/SessionIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/SessionInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/ShutdownInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/SubscriptionInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/TransactionIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/TransactionInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/WireFormatInfoMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

33
activemq-core/src/main/java/org/apache/activemq/openwire/v1/XATransactionIdMarshaller.java
View File

@ -1,27 +1,30 @@
/** /**
* * <a href="http://activemq.org">ActiveMQ: The Open Source Message Fabric</a>
* Copyright 2005-2006 The Apache Software Foundation *
* * Copyright 2005 Hiram Chirino
* Licensed under the Apache License, Version 2.0 (the "License"); * Copyright 2005 Protique Ltd
* you may not use this file except in compliance with the License. *
* You may obtain a copy of the License at * Licensed 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 * http://www.apache.org/licenses/LICENSE-2.0
* *
* Unless required by applicable law or agreed to in writing, software * Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, * distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ *
**/
package org.apache.activemq.openwire.v1; package org.apache.activemq.openwire.v1;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import org.apache.activemq.command.*;
import org.apache.activemq.openwire.*; import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/** /**

3527
openwire-c/src/libopenwire/ow_commands_v1.c
View File

File diff suppressed because it is too large Load Diff

831
openwire-c/src/libopenwire/ow_commands_v1.h
View File

@ -50,52 +50,15 @@ typedef struct ow_MessageId {
ow_MessageId *ow_MessageId_create(apr_pool_t *pool); ow_MessageId *ow_MessageId_create(apr_pool_t *pool);
ow_boolean ow_is_a_MessageId(ow_DataStructure *object); ow_boolean ow_is_a_MessageId(ow_DataStructure *object);
typedef struct ow_SubscriptionInfo { typedef struct ow_SessionId {
ow_byte structType;
ow_string *clientId;
struct ow_ActiveMQDestination *destination;
ow_string *selector;
ow_string *subcriptionName;
} ow_SubscriptionInfo;
ow_SubscriptionInfo *ow_SubscriptionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_SubscriptionInfo(ow_DataStructure *object);
typedef struct ow_ActiveMQDestination {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQDestination;
ow_ActiveMQDestination *ow_ActiveMQDestination_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQDestination(ow_DataStructure *object);
typedef struct ow_ConnectionId {
ow_byte structType; ow_byte structType;
ow_string *connectionId; ow_string *connectionId;
ow_long sessionId;
} ow_ConnectionId; } ow_SessionId;
ow_ConnectionId *ow_ConnectionId_create(apr_pool_t *pool); ow_SessionId *ow_SessionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_ConnectionId(ow_DataStructure *object); ow_boolean ow_is_a_SessionId(ow_DataStructure *object);
typedef struct ow_JournalTrace {
ow_byte structType;
ow_string *message;
} ow_JournalTrace;
ow_JournalTrace *ow_JournalTrace_create(apr_pool_t *pool);
ow_boolean ow_is_a_JournalTrace(ow_DataStructure *object);
typedef struct ow_KeepAliveInfo {
ow_byte structType;
} ow_KeepAliveInfo;
ow_KeepAliveInfo *ow_KeepAliveInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_KeepAliveInfo(ow_DataStructure *object);
typedef struct ow_JournalQueueAck { typedef struct ow_JournalQueueAck {
@ -107,14 +70,41 @@ typedef struct ow_JournalQueueAck {
ow_JournalQueueAck *ow_JournalQueueAck_create(apr_pool_t *pool); ow_JournalQueueAck *ow_JournalQueueAck_create(apr_pool_t *pool);
ow_boolean ow_is_a_JournalQueueAck(ow_DataStructure *object); ow_boolean ow_is_a_JournalQueueAck(ow_DataStructure *object);
typedef struct ow_BrokerId { typedef struct ow_WireFormatInfo {
ow_byte structType; ow_byte structType;
ow_string *brokerId; ow_byte_array *magic;
ow_int version;
ow_int options;
} ow_BrokerId; } ow_WireFormatInfo;
ow_BrokerId *ow_BrokerId_create(apr_pool_t *pool); ow_WireFormatInfo *ow_WireFormatInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_BrokerId(ow_DataStructure *object); ow_boolean ow_is_a_WireFormatInfo(ow_DataStructure *object);
typedef struct ow_TransactionId {
ow_byte structType;
} ow_TransactionId;
ow_TransactionId *ow_TransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_TransactionId(ow_DataStructure *object);
typedef struct ow_ConnectionId {
ow_byte structType;
ow_string *connectionId;
} ow_ConnectionId;
ow_ConnectionId *ow_ConnectionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_ConnectionId(ow_DataStructure *object);
typedef struct ow_KeepAliveInfo {
ow_byte structType;
} ow_KeepAliveInfo;
ow_KeepAliveInfo *ow_KeepAliveInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_KeepAliveInfo(ow_DataStructure *object);
typedef struct ow_BaseCommand { typedef struct ow_BaseCommand {
@ -126,61 +116,58 @@ typedef struct ow_BaseCommand {
ow_BaseCommand *ow_BaseCommand_create(apr_pool_t *pool); ow_BaseCommand *ow_BaseCommand_create(apr_pool_t *pool);
ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object); ow_boolean ow_is_a_BaseCommand(ow_DataStructure *object);
typedef struct ow_SessionInfo { typedef struct ow_XATransactionId {
ow_byte structType; ow_byte structType;
ow_short commandId; ow_int formatId;
ow_boolean responseRequired; ow_byte_array *globalTransactionId;
struct ow_SessionId *sessionId; ow_byte_array *branchQualifier;
} ow_SessionInfo; } ow_XATransactionId;
ow_SessionInfo *ow_SessionInfo_create(apr_pool_t *pool); ow_XATransactionId *ow_XATransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_SessionInfo(ow_DataStructure *object); ow_boolean ow_is_a_XATransactionId(ow_DataStructure *object);
typedef struct ow_Message { typedef struct ow_JournalTrace {
ow_byte structType; ow_byte structType;
ow_short commandId; ow_string *message;
ow_boolean responseRequired;
struct ow_ProducerId *producerId;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ActiveMQDestination *originalDestination;
struct ow_MessageId *messageId;
struct ow_TransactionId *originalTransactionId;
ow_string *groupID;
ow_int groupSequence;
ow_string *correlationId;
ow_boolean persistent;
ow_long expiration;
ow_byte priority;
struct ow_ActiveMQDestination *replyTo;
ow_long timestamp;
ow_string *type;
ow_byte_array *content;
ow_byte_array *marshalledProperties;
struct ow_DataStructure *dataStructure;
struct ow_ConsumerId *targetConsumerId;
ow_boolean compressed;
ow_int redeliveryCounter;
ow_DataStructure_array *brokerPath;
ow_long arrival;
ow_string *userID;
ow_boolean recievedByDFBridge;
} ow_Message; } ow_JournalTrace;
ow_Message *ow_Message_create(apr_pool_t *pool); ow_JournalTrace *ow_JournalTrace_create(apr_pool_t *pool);
ow_boolean ow_is_a_Message(ow_DataStructure *object); ow_boolean ow_is_a_JournalTrace(ow_DataStructure *object);
typedef struct ow_ShutdownInfo { typedef struct ow_FlushCommand {
ow_byte structType; ow_byte structType;
ow_short commandId; ow_short commandId;
ow_boolean responseRequired; ow_boolean responseRequired;
} ow_ShutdownInfo; } ow_FlushCommand;
ow_ShutdownInfo *ow_ShutdownInfo_create(apr_pool_t *pool); ow_FlushCommand *ow_FlushCommand_create(apr_pool_t *pool);
ow_boolean ow_is_a_ShutdownInfo(ow_DataStructure *object); ow_boolean ow_is_a_FlushCommand(ow_DataStructure *object);
typedef struct ow_RedeliveryPolicy {
ow_byte structType;
ow_short backOffMultiplier;
ow_long initialRedeliveryDelay;
ow_int maximumRedeliveries;
ow_boolean useExponentialBackOff;
} ow_RedeliveryPolicy;
ow_RedeliveryPolicy *ow_RedeliveryPolicy_create(apr_pool_t *pool);
ow_boolean ow_is_a_RedeliveryPolicy(ow_DataStructure *object);
typedef struct ow_ConsumerId {
ow_byte structType;
ow_string *connectionId;
ow_long sessionId;
ow_long consumerId;
} ow_ConsumerId;
ow_ConsumerId *ow_ConsumerId_create(apr_pool_t *pool);
ow_boolean ow_is_a_ConsumerId(ow_DataStructure *object);
typedef struct ow_JournalTopicAck { typedef struct ow_JournalTopicAck {
@ -196,6 +183,203 @@ typedef struct ow_JournalTopicAck {
ow_JournalTopicAck *ow_JournalTopicAck_create(apr_pool_t *pool); ow_JournalTopicAck *ow_JournalTopicAck_create(apr_pool_t *pool);
ow_boolean ow_is_a_JournalTopicAck(ow_DataStructure *object); ow_boolean ow_is_a_JournalTopicAck(ow_DataStructure *object);
typedef struct ow_BrokerId {
ow_byte structType;
ow_string *brokerId;
} ow_BrokerId;
ow_BrokerId *ow_BrokerId_create(apr_pool_t *pool);
ow_boolean ow_is_a_BrokerId(ow_DataStructure *object);
typedef struct ow_MessageDispatch {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConsumerId *consumerId;
struct ow_ActiveMQDestination *destination;
struct ow_Message *message;
ow_int redeliveryCounter;
} ow_MessageDispatch;
ow_MessageDispatch *ow_MessageDispatch_create(apr_pool_t *pool);
ow_boolean ow_is_a_MessageDispatch(ow_DataStructure *object);
typedef struct ow_ProducerInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ProducerId *producerId;
struct ow_ActiveMQDestination *destination;
ow_DataStructure_array *brokerPath;
} ow_ProducerInfo;
ow_ProducerInfo *ow_ProducerInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_ProducerInfo(ow_DataStructure *object);
typedef struct ow_SubscriptionInfo {
ow_byte structType;
ow_string *clientId;
struct ow_ActiveMQDestination *destination;
ow_string *selector;
ow_string *subcriptionName;
} ow_SubscriptionInfo;
ow_SubscriptionInfo *ow_SubscriptionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_SubscriptionInfo(ow_DataStructure *object);
typedef struct ow_SessionInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_SessionId *sessionId;
} ow_SessionInfo;
ow_SessionInfo *ow_SessionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_SessionInfo(ow_DataStructure *object);
typedef struct ow_TransactionInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConnectionId *connectionId;
struct ow_TransactionId *transactionId;
ow_byte type;
} ow_TransactionInfo;
ow_TransactionInfo *ow_TransactionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_TransactionInfo(ow_DataStructure *object);
typedef struct ow_ActiveMQDestination {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQDestination;
ow_ActiveMQDestination *ow_ActiveMQDestination_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQDestination(ow_DataStructure *object);
typedef struct ow_MessageAck {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ConsumerId *consumerId;
ow_byte ackType;
struct ow_MessageId *firstMessageId;
struct ow_MessageId *lastMessageId;
ow_int messageCount;
} ow_MessageAck;
ow_MessageAck *ow_MessageAck_create(apr_pool_t *pool);
ow_boolean ow_is_a_MessageAck(ow_DataStructure *object);
typedef struct ow_ProducerId {
ow_byte structType;
ow_string *connectionId;
ow_long producerId;
ow_long sessionId;
} ow_ProducerId;
ow_ProducerId *ow_ProducerId_create(apr_pool_t *pool);
ow_boolean ow_is_a_ProducerId(ow_DataStructure *object);
typedef struct ow_ActiveMQTopic {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQTopic;
ow_ActiveMQTopic *ow_ActiveMQTopic_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTopic(ow_DataStructure *object);
typedef struct ow_JournalTransaction {
ow_byte structType;
struct ow_TransactionId *transactionId;
ow_byte type;
ow_boolean wasPrepared;
} ow_JournalTransaction;
ow_JournalTransaction *ow_JournalTransaction_create(apr_pool_t *pool);
ow_boolean ow_is_a_JournalTransaction(ow_DataStructure *object);
typedef struct ow_RemoveInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_DataStructure *objectId;
} ow_RemoveInfo;
ow_RemoveInfo *ow_RemoveInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_RemoveInfo(ow_DataStructure *object);
typedef struct ow_ControlCommand {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_string *command;
} ow_ControlCommand;
ow_ControlCommand *ow_ControlCommand_create(apr_pool_t *pool);
ow_boolean ow_is_a_ControlCommand(ow_DataStructure *object);
typedef struct ow_BrokerInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_BrokerId *brokerId;
ow_string *brokerURL;
ow_DataStructure_array *peerBrokerInfos;
ow_string *brokerName;
} ow_BrokerInfo;
ow_BrokerInfo *ow_BrokerInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_BrokerInfo(ow_DataStructure *object);
typedef struct ow_LocalTransactionId {
ow_byte structType;
ow_long transactionId;
struct ow_ConnectionId *connectionId;
} ow_LocalTransactionId;
ow_LocalTransactionId *ow_LocalTransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_LocalTransactionId(ow_DataStructure *object);
typedef struct ow_RemoveSubscriptionInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConnectionId *connectionId;
ow_string *subcriptionName;
ow_string *clientId;
} ow_RemoveSubscriptionInfo;
ow_RemoveSubscriptionInfo *ow_RemoveSubscriptionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_RemoveSubscriptionInfo(ow_DataStructure *object);
typedef struct ow_ActiveMQQueue {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQQueue;
ow_ActiveMQQueue *ow_ActiveMQQueue_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQQueue(ow_DataStructure *object);
typedef struct ow_DestinationInfo { typedef struct ow_DestinationInfo {
ow_byte structType; ow_byte structType;
@ -211,26 +395,26 @@ typedef struct ow_DestinationInfo {
ow_DestinationInfo *ow_DestinationInfo_create(apr_pool_t *pool); ow_DestinationInfo *ow_DestinationInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_DestinationInfo(ow_DataStructure *object); ow_boolean ow_is_a_DestinationInfo(ow_DataStructure *object);
typedef struct ow_ConsumerId { typedef struct ow_ShutdownInfo {
ow_byte structType; ow_byte structType;
ow_string *connectionId; ow_short commandId;
ow_long sessionId; ow_boolean responseRequired;
ow_long consumerId;
} ow_ConsumerId; } ow_ShutdownInfo;
ow_ConsumerId *ow_ConsumerId_create(apr_pool_t *pool); ow_ShutdownInfo *ow_ShutdownInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_ConsumerId(ow_DataStructure *object); ow_boolean ow_is_a_ShutdownInfo(ow_DataStructure *object);
typedef struct ow_SessionId { typedef struct ow_Response {
ow_byte structType; ow_byte structType;
ow_string *connectionId; ow_short commandId;
ow_long sessionId; ow_boolean responseRequired;
ow_short correlationId;
} ow_SessionId; } ow_Response;
ow_SessionId *ow_SessionId_create(apr_pool_t *pool); ow_Response *ow_Response_create(apr_pool_t *pool);
ow_boolean ow_is_a_SessionId(ow_DataStructure *object); ow_boolean ow_is_a_Response(ow_DataStructure *object);
typedef struct ow_ConsumerInfo { typedef struct ow_ConsumerInfo {
@ -270,111 +454,49 @@ typedef struct ow_ConnectionInfo {
ow_ConnectionInfo *ow_ConnectionInfo_create(apr_pool_t *pool); ow_ConnectionInfo *ow_ConnectionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_ConnectionInfo(ow_DataStructure *object); ow_boolean ow_is_a_ConnectionInfo(ow_DataStructure *object);
typedef struct ow_ActiveMQTopic { typedef struct ow_Message {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ProducerId *producerId;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ActiveMQDestination *originalDestination;
struct ow_MessageId *messageId;
struct ow_TransactionId *originalTransactionId;
ow_string *groupID;
ow_int groupSequence;
ow_string *correlationId;
ow_boolean persistent;
ow_long expiration;
ow_byte priority;
struct ow_ActiveMQDestination *replyTo;
ow_long timestamp;
ow_string *type;
ow_byte_array *content;
ow_byte_array *marshalledProperties;
struct ow_DataStructure *dataStructure;
struct ow_ConsumerId *targetConsumerId;
ow_boolean compressed;
ow_int redeliveryCounter;
ow_DataStructure_array *brokerPath;
ow_long arrival;
ow_string *userID;
ow_boolean recievedByDFBridge;
} ow_Message;
ow_Message *ow_Message_create(apr_pool_t *pool);
ow_boolean ow_is_a_Message(ow_DataStructure *object);
typedef struct ow_ActiveMQTempDestination {
ow_byte structType; ow_byte structType;
ow_string *physicalName; ow_string *physicalName;
} ow_ActiveMQTopic; } ow_ActiveMQTempDestination;
ow_ActiveMQTopic *ow_ActiveMQTopic_create(apr_pool_t *pool); ow_ActiveMQTempDestination *ow_ActiveMQTempDestination_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTopic(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQTempDestination(ow_DataStructure *object);
typedef struct ow_RedeliveryPolicy {
ow_byte structType;
ow_short backOffMultiplier;
ow_long initialRedeliveryDelay;
ow_int maximumRedeliveries;
ow_boolean useExponentialBackOff;
} ow_RedeliveryPolicy;
ow_RedeliveryPolicy *ow_RedeliveryPolicy_create(apr_pool_t *pool);
ow_boolean ow_is_a_RedeliveryPolicy(ow_DataStructure *object);
typedef struct ow_JournalTransaction {
ow_byte structType;
struct ow_TransactionId *transactionId;
ow_byte type;
ow_boolean wasPrepared;
} ow_JournalTransaction;
ow_JournalTransaction *ow_JournalTransaction_create(apr_pool_t *pool);
ow_boolean ow_is_a_JournalTransaction(ow_DataStructure *object);
typedef struct ow_ProducerId {
ow_byte structType;
ow_string *connectionId;
ow_long producerId;
ow_long sessionId;
} ow_ProducerId;
ow_ProducerId *ow_ProducerId_create(apr_pool_t *pool);
ow_boolean ow_is_a_ProducerId(ow_DataStructure *object);
typedef struct ow_ActiveMQQueue {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQQueue;
ow_ActiveMQQueue *ow_ActiveMQQueue_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQQueue(ow_DataStructure *object);
typedef struct ow_TransactionInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConnectionId *connectionId;
struct ow_TransactionId *transactionId;
ow_byte type;
} ow_TransactionInfo;
ow_TransactionInfo *ow_TransactionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_TransactionInfo(ow_DataStructure *object);
typedef struct ow_Response {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
} ow_Response;
ow_Response *ow_Response_create(apr_pool_t *pool);
ow_boolean ow_is_a_Response(ow_DataStructure *object);
typedef struct ow_RemoveInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_DataStructure *objectId;
} ow_RemoveInfo;
ow_RemoveInfo *ow_RemoveInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_RemoveInfo(ow_DataStructure *object);
typedef struct ow_WireFormatInfo {
ow_byte structType;
ow_byte_array *magic;
ow_int version;
ow_int options;
} ow_WireFormatInfo;
ow_WireFormatInfo *ow_WireFormatInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_WireFormatInfo(ow_DataStructure *object);
typedef struct ow_TransactionId {
ow_byte structType;
} ow_TransactionId;
ow_TransactionId *ow_TransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_TransactionId(ow_DataStructure *object);
typedef struct ow_ActiveMQMessage { typedef struct ow_ActiveMQMessage {
@ -411,102 +533,6 @@ typedef struct ow_ActiveMQMessage {
ow_ActiveMQMessage *ow_ActiveMQMessage_create(apr_pool_t *pool); ow_ActiveMQMessage *ow_ActiveMQMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQMessage(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQMessage(ow_DataStructure *object);
typedef struct ow_ControlCommand {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_string *command;
} ow_ControlCommand;
ow_ControlCommand *ow_ControlCommand_create(apr_pool_t *pool);
ow_boolean ow_is_a_ControlCommand(ow_DataStructure *object);
typedef struct ow_FlushCommand {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
} ow_FlushCommand;
ow_FlushCommand *ow_FlushCommand_create(apr_pool_t *pool);
ow_boolean ow_is_a_FlushCommand(ow_DataStructure *object);
typedef struct ow_IntegerResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
ow_int result;
} ow_IntegerResponse;
ow_IntegerResponse *ow_IntegerResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_IntegerResponse(ow_DataStructure *object);
typedef struct ow_RemoveSubscriptionInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConnectionId *connectionId;
ow_string *subcriptionName;
ow_string *clientId;
} ow_RemoveSubscriptionInfo;
ow_RemoveSubscriptionInfo *ow_RemoveSubscriptionInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_RemoveSubscriptionInfo(ow_DataStructure *object);
typedef struct ow_ActiveMQTempDestination {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQTempDestination;
ow_ActiveMQTempDestination *ow_ActiveMQTempDestination_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTempDestination(ow_DataStructure *object);
typedef struct ow_DataArrayResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
ow_DataStructure_array *data;
} ow_DataArrayResponse;
ow_DataArrayResponse *ow_DataArrayResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_DataArrayResponse(ow_DataStructure *object);
typedef struct ow_BrokerInfo {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_BrokerId *brokerId;
ow_string *brokerURL;
ow_DataStructure_array *peerBrokerInfos;
struct ow_RedeliveryPolicy *redeliveryPolicy;
ow_string *brokerName;
} ow_BrokerInfo;
ow_BrokerInfo *ow_BrokerInfo_create(apr_pool_t *pool);
ow_boolean ow_is_a_BrokerInfo(ow_DataStructure *object);
typedef struct ow_MessageDispatch {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ConsumerId *consumerId;
struct ow_ActiveMQDestination *destination;
struct ow_Message *message;
ow_int redeliveryCounter;
} ow_MessageDispatch;
ow_MessageDispatch *ow_MessageDispatch_create(apr_pool_t *pool);
ow_boolean ow_is_a_MessageDispatch(ow_DataStructure *object);
typedef struct ow_ActiveMQStreamMessage { typedef struct ow_ActiveMQStreamMessage {
ow_byte structType; ow_byte structType;
@ -542,44 +568,38 @@ typedef struct ow_ActiveMQStreamMessage {
ow_ActiveMQStreamMessage *ow_ActiveMQStreamMessage_create(apr_pool_t *pool); ow_ActiveMQStreamMessage *ow_ActiveMQStreamMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQStreamMessage(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQStreamMessage(ow_DataStructure *object);
typedef struct ow_ActiveMQTempTopic { typedef struct ow_ExceptionResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
ow_throwable *exception;
} ow_ExceptionResponse;
ow_ExceptionResponse *ow_ExceptionResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_ExceptionResponse(ow_DataStructure *object);
typedef struct ow_ActiveMQTempQueue {
ow_byte structType; ow_byte structType;
ow_string *physicalName; ow_string *physicalName;
} ow_ActiveMQTempTopic; } ow_ActiveMQTempQueue;
ow_ActiveMQTempTopic *ow_ActiveMQTempTopic_create(apr_pool_t *pool); ow_ActiveMQTempQueue *ow_ActiveMQTempQueue_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTempTopic(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQTempQueue(ow_DataStructure *object);
typedef struct ow_ProducerInfo { typedef struct ow_IntegerResponse {
ow_byte structType; ow_byte structType;
ow_short commandId; ow_short commandId;
ow_boolean responseRequired; ow_boolean responseRequired;
struct ow_ProducerId *producerId; ow_short correlationId;
struct ow_ActiveMQDestination *destination; ow_int result;
ow_DataStructure_array *brokerPath;
} ow_ProducerInfo; } ow_IntegerResponse;
ow_ProducerInfo *ow_ProducerInfo_create(apr_pool_t *pool); ow_IntegerResponse *ow_IntegerResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_ProducerInfo(ow_DataStructure *object); ow_boolean ow_is_a_IntegerResponse(ow_DataStructure *object);
typedef struct ow_MessageAck {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ConsumerId *consumerId;
ow_byte ackType;
struct ow_MessageId *firstMessageId;
struct ow_MessageId *lastMessageId;
ow_int messageCount;
} ow_MessageAck;
ow_MessageAck *ow_MessageAck_create(apr_pool_t *pool);
ow_boolean ow_is_a_MessageAck(ow_DataStructure *object);
typedef struct ow_ActiveMQBytesMessage { typedef struct ow_ActiveMQBytesMessage {
@ -616,6 +636,74 @@ typedef struct ow_ActiveMQBytesMessage {
ow_ActiveMQBytesMessage *ow_ActiveMQBytesMessage_create(apr_pool_t *pool); ow_ActiveMQBytesMessage *ow_ActiveMQBytesMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQBytesMessage(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQBytesMessage(ow_DataStructure *object);
typedef struct ow_DataResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
struct ow_DataStructure *data;
} ow_DataResponse;
ow_DataResponse *ow_DataResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_DataResponse(ow_DataStructure *object);
typedef struct ow_DataArrayResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
ow_DataStructure_array *data;
} ow_DataArrayResponse;
ow_DataArrayResponse *ow_DataArrayResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_DataArrayResponse(ow_DataStructure *object);
typedef struct ow_ActiveMQObjectMessage {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ProducerId *producerId;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ActiveMQDestination *originalDestination;
struct ow_MessageId *messageId;
struct ow_TransactionId *originalTransactionId;
ow_string *groupID;
ow_int groupSequence;
ow_string *correlationId;
ow_boolean persistent;
ow_long expiration;
ow_byte priority;
struct ow_ActiveMQDestination *replyTo;
ow_long timestamp;
ow_string *type;
ow_byte_array *content;
ow_byte_array *marshalledProperties;
struct ow_DataStructure *dataStructure;
struct ow_ConsumerId *targetConsumerId;
ow_boolean compressed;
ow_int redeliveryCounter;
ow_DataStructure_array *brokerPath;
ow_long arrival;
ow_string *userID;
ow_boolean recievedByDFBridge;
} ow_ActiveMQObjectMessage;
ow_ActiveMQObjectMessage *ow_ActiveMQObjectMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQObjectMessage(ow_DataStructure *object);
typedef struct ow_ActiveMQTempTopic {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQTempTopic;
ow_ActiveMQTempTopic *ow_ActiveMQTempTopic_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTempTopic(ow_DataStructure *object);
typedef struct ow_ActiveMQTextMessage { typedef struct ow_ActiveMQTextMessage {
ow_byte structType; ow_byte structType;
@ -686,95 +774,6 @@ typedef struct ow_ActiveMQMapMessage {
ow_ActiveMQMapMessage *ow_ActiveMQMapMessage_create(apr_pool_t *pool); ow_ActiveMQMapMessage *ow_ActiveMQMapMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQMapMessage(ow_DataStructure *object); ow_boolean ow_is_a_ActiveMQMapMessage(ow_DataStructure *object);
typedef struct ow_DataResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
struct ow_DataStructure *data;
} ow_DataResponse;
ow_DataResponse *ow_DataResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_DataResponse(ow_DataStructure *object);
typedef struct ow_XATransactionId {
ow_byte structType;
ow_int formatId;
ow_byte_array *globalTransactionId;
ow_byte_array *branchQualifier;
} ow_XATransactionId;
ow_XATransactionId *ow_XATransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_XATransactionId(ow_DataStructure *object);
typedef struct ow_ActiveMQObjectMessage {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
struct ow_ProducerId *producerId;
struct ow_ActiveMQDestination *destination;
struct ow_TransactionId *transactionId;
struct ow_ActiveMQDestination *originalDestination;
struct ow_MessageId *messageId;
struct ow_TransactionId *originalTransactionId;
ow_string *groupID;
ow_int groupSequence;
ow_string *correlationId;
ow_boolean persistent;
ow_long expiration;
ow_byte priority;
struct ow_ActiveMQDestination *replyTo;
ow_long timestamp;
ow_string *type;
ow_byte_array *content;
ow_byte_array *marshalledProperties;
struct ow_DataStructure *dataStructure;
struct ow_ConsumerId *targetConsumerId;
ow_boolean compressed;
ow_int redeliveryCounter;
ow_DataStructure_array *brokerPath;
ow_long arrival;
ow_string *userID;
ow_boolean recievedByDFBridge;
} ow_ActiveMQObjectMessage;
ow_ActiveMQObjectMessage *ow_ActiveMQObjectMessage_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQObjectMessage(ow_DataStructure *object);
typedef struct ow_ExceptionResponse {
ow_byte structType;
ow_short commandId;
ow_boolean responseRequired;
ow_short correlationId;
ow_throwable *exception;
} ow_ExceptionResponse;
ow_ExceptionResponse *ow_ExceptionResponse_create(apr_pool_t *pool);
ow_boolean ow_is_a_ExceptionResponse(ow_DataStructure *object);
typedef struct ow_ActiveMQTempQueue {
ow_byte structType;
ow_string *physicalName;
} ow_ActiveMQTempQueue;
ow_ActiveMQTempQueue *ow_ActiveMQTempQueue_create(apr_pool_t *pool);
ow_boolean ow_is_a_ActiveMQTempQueue(ow_DataStructure *object);
typedef struct ow_LocalTransactionId {
ow_byte structType;
ow_long transactionId;
struct ow_ConnectionId *connectionId;
} ow_LocalTransactionId;
ow_LocalTransactionId *ow_LocalTransactionId_create(apr_pool_t *pool);
ow_boolean ow_is_a_LocalTransactionId(ow_DataStructure *object);
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif