svn commit: r387665 [9/9] - in /incubator/activemq/trunk: activecluster/src/java/org/apache/activecluster/impl/ activemq-core/src/main/java/org/apache/activemq/advisory/ activemq-core/src/main/java/org/apache/activemq/broker/jmx/ activemq-core/src/main...

[ch...@apache.org]

Modified: incubator/activemq/trunk/activemq-soaktest/src/test/java/org/apache/activemq/tool/Producer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-soaktest/src/test/java/org/apache/activemq/tool/Producer.java?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-soaktest/src/test/java/org/apache/activemq/tool/Producer.java (original)
+++ incubator/activemq/trunk/activemq-soaktest/src/test/java/org/apache/activemq/tool/Producer.java Tue Mar 21 15:20:55 2006
@@ -1,68 +1,68 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * 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
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.tool;
-
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.DeliveryMode;
-import javax.jms.Destination;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
-/**
- * @version $Revision: 1.3 $
- */
-public class Producer{
-    protected Connection connection;
-    protected MessageProducer producer;
-    public Producer(ConnectionFactory fac,Destination dest) throws JMSException{
-        connection=fac.createConnection();
-        Session s=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
-        producer=s.createProducer(dest);
-    }
-    public void setDeliveryMode(int mode) throws JMSException{
-        producer.setDeliveryMode(mode);
-    }
-    public void start() throws JMSException{
-        connection.start();
-    }
-    public void stop() throws JMSException{
-        connection.stop();
-    }
-    public void shutDown() throws JMSException{
-        connection.close();
-    }
-
-    public void sendMessage(Message msg) throws JMSException {
-        sendMessage(msg, null,0);
-    }
-
-    /*
-    *   allow producer to attach message counter on its header. This will be used to verify message order
-    *
-    */
-    public void sendMessage(Message msg, String headerName, long headerValue) throws JMSException{
-        if(headerName != null) {
-            msg.setLongProperty(headerName, headerValue);
-        }
-
-        producer.send(msg);
-
-    }
-
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * 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
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.tool;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.DeliveryMode;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+/**
+ * @version $Revision: 1.3 $
+ */
+public class Producer{
+    protected Connection connection;
+    protected MessageProducer producer;
+    public Producer(ConnectionFactory fac,Destination dest) throws JMSException{
+        connection=fac.createConnection();
+        Session s=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
+        producer=s.createProducer(dest);
+    }
+    public void setDeliveryMode(int mode) throws JMSException{
+        producer.setDeliveryMode(mode);
+    }
+    public void start() throws JMSException{
+        connection.start();
+    }
+    public void stop() throws JMSException{
+        connection.stop();
+    }
+    public void shutDown() throws JMSException{
+        connection.close();
+    }
+
+    public void sendMessage(Message msg) throws JMSException {
+        sendMessage(msg, null,0);
+    }
+
+    /*
+    *   allow producer to attach message counter on its header. This will be used to verify message order
+    *
+    */
+    public void sendMessage(Message msg, String headerName, long headerValue) throws JMSException{
+        if(headerName != null) {
+            msg.setLongProperty(headerName, headerValue);
+        }
+
+        producer.send(msg);
+
+    }
+
 }

Propchange: incubator/activemq/trunk/activemq-soaktest/src/test/java/org/apache/activemq/tool/Producer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/command/NetworkBridgeFilter.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/command/NetworkBridgeFilter.cpp?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/command/NetworkBridgeFilter.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/command/NetworkBridgeFilter.cpp Tue Mar 21 15:20:55 2006
@@ -1 +1,61 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* 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
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "command/NetworkBridgeFilter.hpp"

using namespace apache::activemq::client::command;

/*
 *
 *  Marshalling code for Open Wire Format for NetworkBridgeFilter
 *
 *
 *  NOTE!: This file is autogenerated - do not modify!
 *         if you need to make a change, please see the Groovy scripts in the
 *         activemq-core module
 *
 */
NetworkB
 ridgeFilter::NetworkBridgeFilter()
{
    this->networkTTL = 0 ;
    this->networkBrokerId = 0 ;
}

NetworkBridgeFilter::~NetworkBridgeFilter()
{
}

        
int NetworkBridgeFilter::getNetworkTTL()
{
    return networkTTL ;
}

void NetworkBridgeFilter::setNetworkTTL(int networkTTL)
{
    this->networkTTL = networkTTL ;
}

        
p<BrokerId> NetworkBridgeFilter::getNetworkBrokerId()
{
    return networkBrokerId ;
}

void NetworkBridgeFilter::setNetworkBrokerId(p<BrokerId> networkBrokerId)
{
    this->networkBrokerId = networkBrokerId ;
}
\ No newline at end of file
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* 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
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+#include "command/NetworkBridgeFilter.hpp"
+
+using namespace apache::activemq::client::command;
+
+/*
+ *
+ *  Marshalling code for Open Wire Format for NetworkBridgeFilter
+ *
+ *
+ *  NOTE!: This file is autogenerated - do not modify!
+ *         if you need to make a change, please see the Groovy scripts in the
+ *         activemq-core module
+ *
+ */
+NetworkBridgeFilter::NetworkBridgeFilter()
+{
+    this->networkTTL = 0 ;
+    this->networkBrokerId = 0 ;
+}
+
+NetworkBridgeFilter::~NetworkBridgeFilter()
+{
+}
+
+        
+int NetworkBridgeFilter::getNetworkTTL()
+{
+    return networkTTL ;
+}
+
+void NetworkBridgeFilter::setNetworkTTL(int networkTTL)
+{
+    this->networkTTL = networkTTL ;
+}
+
+        
+p<BrokerId> NetworkBridgeFilter::getNetworkBrokerId()
+{
+    return networkBrokerId ;
+}
+
+void NetworkBridgeFilter::setNetworkBrokerId(p<BrokerId> networkBrokerId)
+{
+    this->networkBrokerId = networkBrokerId ;
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/command/NetworkBridgeFilter.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp (original)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp Tue Mar 21 15:20:55 2006
@@ -1 +1,87 @@
-/*
 * Copyright 2006 The Apache Software Foundation or its licensors, as
 * applicable.
 *
 * 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
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#include "marshal/NetworkBridgeFilterMarshaller.hpp"

using namespace apache::activemq::client::marshal;

/*
 *  Marshalling code for Open Wire Format for NetworkBridgeFilter
 *
 * NOTE!: This file is autogenerated - do not modify!
 *        if you need to make a change, please see the Groovy scripts in the
 *        activemq-core module
 
 */

NetworkBridgeFilterMarshaller::NetworkBridgeFilterMarshaller()
{
    // no-op
}

NetworkBridgeFilterMarshaller::~NetworkBridgeFilterMarshaller()
{
    // no-op
}



IDataStructure* NetworkBridgeFilterMarshaller::createObject() 
{
    return new NetworkBridgeFilter();
}

char NetworkBridgeFilterMarshaller::getDataStructureType() 
{
    return NetworkBridgeFilter.ID_NetworkBridgeFilter;
}

    /* 
     * Un-marshal an object instance from the data input stream
     */ 
void NetworkBridgeFilterMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
{
    base.unmarshal(wireFormat, o, dataIn, bs);

    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;
        info.setNetworkTTL(dataIn.readInt());
        info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));

}


/*
 * Write the booleans that this object uses to a BooleanStream
 */
int NetworkBridgeFilterMarshaller
 ::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;

    int rc = base.marshal1(wireFormat, info, bs);
        rc += marshal1CachedObject(wireFormat, info.getNetworkBrokerId(), bs);

    return rc + 1;
}

/* 
 * Write a object instance to data output stream
 */
void NetworkBridgeFilterMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
    base.marshal2(wireFormat, o, dataOut, bs);

    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;
    DataStreamMarshaller.writeInt(info.getNetworkTTL(), dataOut);
    marshal2CachedObject(wireFormat, info.getNetworkBrokerId(), dataOut, bs);

}
\ No newline at end of file
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * 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
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "marshal/NetworkBridgeFilterMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for NetworkBridgeFilter
+ *
+ * NOTE!: This file is autogenerated - do not modify!
+ *        if you need to make a change, please see the Groovy scripts in the
+ *        activemq-core module
+ */
+
+NetworkBridgeFilterMarshaller::NetworkBridgeFilterMarshaller()
+{
+    // no-op
+}
+
+NetworkBridgeFilterMarshaller::~NetworkBridgeFilterMarshaller()
+{
+    // no-op
+}
+
+
+
+IDataStructure* NetworkBridgeFilterMarshaller::createObject() 
+{
+    return new NetworkBridgeFilter();
+}
+
+char NetworkBridgeFilterMarshaller::getDataStructureType() 
+{
+    return NetworkBridgeFilter.ID_NetworkBridgeFilter;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void NetworkBridgeFilterMarshaller::unmarshal(ProtocolFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;
+        info.setNetworkTTL(dataIn.readInt());
+        info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int NetworkBridgeFilterMarshaller::marshal1(ProtocolFormat& wireFormat, Object& o, BooleanStream& bs) {
+    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+        rc += marshal1CachedObject(wireFormat, info.getNetworkBrokerId(), bs);
+
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void NetworkBridgeFilterMarshaller::marshal2(ProtocolFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    NetworkBridgeFilter& info = (NetworkBridgeFilter&) o;
+    DataStreamMarshaller.writeInt(info.getNetworkTTL(), dataOut);
+    marshal2CachedObject(wireFormat, info.getNetworkBrokerId(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/NetworkBridgeFilterMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/stomp/php/Stomp.php
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/stomp/php/Test.php
------------------------------------------------------------------------------
    svn:eol-style = native