activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r379619 [30/30] - in /incubator/activemq/trunk: ./ activecluster/ activecluster/src/java/org/apache/activecluster/ activecluster/src/java/org/apache/activecluster/election/ activecluster/src/java/org/apache/activecluster/election/impl/ acti...
Date Tue, 21 Feb 2006 23:14:17 GMT
Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/ClientArgs.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/ClientArgs.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/ClientArgs.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/ClientArgs.java Tue Feb 21 15:12:56 2006
@@ -1,92 +1,92 @@
-/** 
- * 
- * Copyright 2004 Michael Gaffney
- * 
- * 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 com.panacya.platform.service.bus.client;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-public class ClientArgs {
-    private long timeout = -1;
-    private String command;
-    private String destination;
-
-    private int noOfMessages = 1;
-
-    public ClientArgs(String[] args) {
-        /*
-        int argCount = args.length;
-
-        System.out.println(argCount);
-        for(int i = 0 ; i < argCount; i++){
-            System.out.println(args[i] + " ..........");
-        }
-         */
-        switch (args.length) {
-            case 4:
-                setNoOfMessages(args[3]);
-            case 3:
-                setTimeout(args[2]);
-            case 2:
-                destination = args[1];
-                command = args[0];
-                break;
-            default :
-                printHelp();
-        }
-    }
-
-    public String getCommand() {
-        return command;
-    }
-
-    public String getDestination() {
-        return destination;
-    }
-
-    public long getTimeout() {
-        return timeout;
-    }
-
-    private void setTimeout(String timout) {
-        if (!isEmpty(timout)) {
-            try {
-                timeout = Long.valueOf(timout).longValue();
-            } catch (NumberFormatException e) {
-                System.err.println(e.toString());
-            }
-        }
-    }
-
-    public int getNoOfMessages() {
-        return noOfMessages;
-    }
-
-    public void setNoOfMessages(String count) {
-        System.out.println("noOfMessage " + count);
-        this.noOfMessages = Integer.parseInt(count);
-    }
-
-    private static boolean isEmpty(String value) {
-        return value == null || "".equals(value.trim());
-    }
-
-    private static void printHelp() {
-        System.out.println("JmsSimpleClient command(send | receive | send-receive) noOfMessages destination timeout");
-    }
-}    
-
+/** 
+ * 
+ * Copyright 2004 Michael Gaffney
+ * 
+ * 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 com.panacya.platform.service.bus.client;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+public class ClientArgs {
+    private long timeout = -1;
+    private String command;
+    private String destination;
+
+    private int noOfMessages = 1;
+
+    public ClientArgs(String[] args) {
+        /*
+        int argCount = args.length;
+
+        System.out.println(argCount);
+        for(int i = 0 ; i < argCount; i++){
+            System.out.println(args[i] + " ..........");
+        }
+         */
+        switch (args.length) {
+            case 4:
+                setNoOfMessages(args[3]);
+            case 3:
+                setTimeout(args[2]);
+            case 2:
+                destination = args[1];
+                command = args[0];
+                break;
+            default :
+                printHelp();
+        }
+    }
+
+    public String getCommand() {
+        return command;
+    }
+
+    public String getDestination() {
+        return destination;
+    }
+
+    public long getTimeout() {
+        return timeout;
+    }
+
+    private void setTimeout(String timout) {
+        if (!isEmpty(timout)) {
+            try {
+                timeout = Long.valueOf(timout).longValue();
+            } catch (NumberFormatException e) {
+                System.err.println(e.toString());
+            }
+        }
+    }
+
+    public int getNoOfMessages() {
+        return noOfMessages;
+    }
+
+    public void setNoOfMessages(String count) {
+        System.out.println("noOfMessage " + count);
+        this.noOfMessages = Integer.parseInt(count);
+    }
+
+    private static boolean isEmpty(String value) {
+        return value == null || "".equals(value.trim());
+    }
+
+    private static void printHelp() {
+        System.out.println("JmsSimpleClient command(send | receive | send-receive) noOfMessages destination timeout");
+    }
+}    
+

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/ClientArgs.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/JmsSimpleClient.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/JmsSimpleClient.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/JmsSimpleClient.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/JmsSimpleClient.java Tue Feb 21 15:12:56 2006
@@ -1,124 +1,124 @@
-package com.panacya.platform.service.bus.client;
-
-import org.activemq.ActiveMQConnectionFactory;
-import org.springframework.jms.core.JmsTemplate;
-import org.springframework.jms.core.MessageCreator;
-
-import javax.jms.Message;
-import javax.jms.Session;
-import javax.jms.JMSException;
-import javax.naming.InitialContext;
-import javax.naming.Context;
-import javax.naming.NamingException;
-import javax.jms.ConnectionFactory;
-
-import org.activemq.util.IdGenerator;
-
-import java.util.Properties;
-import java.lang.reflect.InvocationTargetException;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-public class JmsSimpleClient {
-
-    private static final String BROKER_URL = "tcp://localhost:61616";
-    //private static final String BROKER_URL = "jnp://localhost:1099";
-    private static final String SEND_CMD = "send";
-    private static final String RECEIVE_CMD = "receive";
-    private static final String ENDLESS_RECEIVE_CMD = "receive-non-stop";
-    private static final String SEND_RECEIVE_CMD = "send-receive";
-
-    public static final String NAMING_CONTEXT = "org.jnp.interfaces.NamingContextFactory";
-    public static final String JNP_INTERFACES = "org.jnp.interfaces";
-
-
-    public static void main(String[] args) {
-        execute(new ClientArgs(args));
-    }
-
-    private static void execute(ClientArgs args) {
-        try {
-            if (SEND_CMD.equals(args.getCommand())) {
-                JmsSimpleClient.sendToActiveMQ(args.getDestination(), args.getNoOfMessages());
-            } else if (RECEIVE_CMD.equals(args.getCommand())) {
-                JmsSimpleClient.receiveFromActiveMQ(args.getDestination(), args.getTimeout());
-            } else if (ENDLESS_RECEIVE_CMD.equals(args.getCommand())) {
-                JmsSimpleClient.receiveFromActiveMQ(args.getDestination());
-            } else if (SEND_RECEIVE_CMD.equals(args.getCommand())) {
-                JmsSimpleClient.sendToActiveMQ(args.getDestination(), args.getNoOfMessages());
-                JmsSimpleClient.receiveFromActiveMQ(args.getDestination(), args.getTimeout());
-            } else {
-                System.err.println("Unknown command: " + args.getCommand());
-                System.exit(-1);
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-
-    public static void sendToActiveMQ(String destinationName, int count) throws Exception {
-        System.out.println("Sending to '" + destinationName + "' ...");
-        JmsTemplate jt = createTemplate(destinationName);
-
-        int i = 0;
-        for (; i < count; i++) {
-            jt.send(destinationName, new MessageCreator() {
-                public Message createMessage(Session session) throws JMSException {
-                    return session.createTextMessage("hello ActiveMQ world ");
-                }
-            });
-        }
-
-        System.out.println("Done sending " + count + " message/s ........");
-    }
-
-    public static void receiveFromActiveMQ(String destinationName, long timeout) throws Exception {
-        System.out.println("Listening to '" + destinationName + "' ...");
-        JmsTemplate jt = createTemplate(destinationName);
-        jt.setReceiveTimeout(timeout);
-        while (true) {
-            Message aMessage = jt.receive(destinationName);
-            System.out.println("...done");
-            if (aMessage == null) {
-                System.out.println("No message received");
-            } else {
-                System.out.println("Message Received: " + aMessage.toString());
-            }
-        }
-    }
-
-    public static void receiveFromActiveMQ(String destinationName) throws Exception {
-        System.out.println("Listening to '" + destinationName + "' ...");
-        JmsTemplate jt = createTemplate(destinationName);
-
-        while (true) {
-            Message aMessage = jt.receive(destinationName);
-            if (aMessage == null) {
-                System.out.println("No message received");
-            } else {
-                int messageNumber = aMessage.getIntProperty("MessageNumber");
-                System.out.println("Received MessageNumber: " + messageNumber);
-            }
-        }
-    }
-
-    private static JmsTemplate createTemplate(String destinationName) {
-
-        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
-        connectionFactory.setBrokerURL(BROKER_URL);
-
-        IdGenerator idGenerator = new IdGenerator();
-        connectionFactory.setClientID(idGenerator.generateId());
-
-        JmsTemplate jt = new JmsTemplate(connectionFactory);
-        if (destinationName.startsWith("topic")) {
-            jt.setPubSubDomain(true);
-        }
-
-        return jt;
-
-    }
-
-
-}
+package com.panacya.platform.service.bus.client;
+
+import org.activemq.ActiveMQConnectionFactory;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.jms.core.MessageCreator;
+
+import javax.jms.Message;
+import javax.jms.Session;
+import javax.jms.JMSException;
+import javax.naming.InitialContext;
+import javax.naming.Context;
+import javax.naming.NamingException;
+import javax.jms.ConnectionFactory;
+
+import org.activemq.util.IdGenerator;
+
+import java.util.Properties;
+import java.lang.reflect.InvocationTargetException;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+public class JmsSimpleClient {
+
+    private static final String BROKER_URL = "tcp://localhost:61616";
+    //private static final String BROKER_URL = "jnp://localhost:1099";
+    private static final String SEND_CMD = "send";
+    private static final String RECEIVE_CMD = "receive";
+    private static final String ENDLESS_RECEIVE_CMD = "receive-non-stop";
+    private static final String SEND_RECEIVE_CMD = "send-receive";
+
+    public static final String NAMING_CONTEXT = "org.jnp.interfaces.NamingContextFactory";
+    public static final String JNP_INTERFACES = "org.jnp.interfaces";
+
+
+    public static void main(String[] args) {
+        execute(new ClientArgs(args));
+    }
+
+    private static void execute(ClientArgs args) {
+        try {
+            if (SEND_CMD.equals(args.getCommand())) {
+                JmsSimpleClient.sendToActiveMQ(args.getDestination(), args.getNoOfMessages());
+            } else if (RECEIVE_CMD.equals(args.getCommand())) {
+                JmsSimpleClient.receiveFromActiveMQ(args.getDestination(), args.getTimeout());
+            } else if (ENDLESS_RECEIVE_CMD.equals(args.getCommand())) {
+                JmsSimpleClient.receiveFromActiveMQ(args.getDestination());
+            } else if (SEND_RECEIVE_CMD.equals(args.getCommand())) {
+                JmsSimpleClient.sendToActiveMQ(args.getDestination(), args.getNoOfMessages());
+                JmsSimpleClient.receiveFromActiveMQ(args.getDestination(), args.getTimeout());
+            } else {
+                System.err.println("Unknown command: " + args.getCommand());
+                System.exit(-1);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void sendToActiveMQ(String destinationName, int count) throws Exception {
+        System.out.println("Sending to '" + destinationName + "' ...");
+        JmsTemplate jt = createTemplate(destinationName);
+
+        int i = 0;
+        for (; i < count; i++) {
+            jt.send(destinationName, new MessageCreator() {
+                public Message createMessage(Session session) throws JMSException {
+                    return session.createTextMessage("hello ActiveMQ world ");
+                }
+            });
+        }
+
+        System.out.println("Done sending " + count + " message/s ........");
+    }
+
+    public static void receiveFromActiveMQ(String destinationName, long timeout) throws Exception {
+        System.out.println("Listening to '" + destinationName + "' ...");
+        JmsTemplate jt = createTemplate(destinationName);
+        jt.setReceiveTimeout(timeout);
+        while (true) {
+            Message aMessage = jt.receive(destinationName);
+            System.out.println("...done");
+            if (aMessage == null) {
+                System.out.println("No message received");
+            } else {
+                System.out.println("Message Received: " + aMessage.toString());
+            }
+        }
+    }
+
+    public static void receiveFromActiveMQ(String destinationName) throws Exception {
+        System.out.println("Listening to '" + destinationName + "' ...");
+        JmsTemplate jt = createTemplate(destinationName);
+
+        while (true) {
+            Message aMessage = jt.receive(destinationName);
+            if (aMessage == null) {
+                System.out.println("No message received");
+            } else {
+                int messageNumber = aMessage.getIntProperty("MessageNumber");
+                System.out.println("Received MessageNumber: " + messageNumber);
+            }
+        }
+    }
+
+    private static JmsTemplate createTemplate(String destinationName) {
+
+        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
+        connectionFactory.setBrokerURL(BROKER_URL);
+
+        IdGenerator idGenerator = new IdGenerator();
+        connectionFactory.setClientID(idGenerator.generateId());
+
+        JmsTemplate jt = new JmsTemplate(connectionFactory);
+        if (destinationName.startsWith("topic")) {
+            jt.setPubSubDomain(true);
+        }
+
+        return jt;
+
+    }
+
+
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/client/JmsSimpleClient.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/mdb/SimpleMessageReceiverBean.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/mdb/SimpleMessageReceiverBean.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/mdb/SimpleMessageReceiverBean.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/mdb/SimpleMessageReceiverBean.java Tue Feb 21 15:12:56 2006
@@ -1,95 +1,95 @@
-package com.panacya.platform.service.bus.mdb;
-
-import com.panacya.platform.service.bus.sender.SenderClient;
-import com.panacya.platform.service.bus.sender.SenderException;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-import javax.ejb.CreateException;
-import javax.ejb.MessageDrivenBean;
-import javax.ejb.MessageDrivenContext;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageListener;
-import javax.jms.TextMessage;
-import javax.naming.NamingException;
-import java.rmi.RemoteException;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-
-public class SimpleMessageReceiverBean implements MessageDrivenBean, MessageListener {
-
-    private static final String SENDER_NAME = "java:comp/env/ejb/Sender";
-    private Log _log = LogFactory.getLog(SimpleMessageReceiverBean.class);
-    private MessageDrivenContext context;
-
-    public SimpleMessageReceiverBean() {
-        if (_log.isInfoEnabled()) {
-            _log.info("SimpleMessageReceiverBean.SimpleMessageReceiverBean");
-        }
-    }
-
-    public void onMessage(Message message)  {
-        if (_log.isInfoEnabled()) {
-            _log.info("SimpleMessageReceiverBean.onMessage");
-        }
-        try {
-            handleMessage(message);
-        } catch (JMSException e) {
-            _log.error(e.toString(), e);
-        } catch (NamingException e) {
-            _log.error(e.toString(), e);
-        } catch (RemoteException e) {
-            _log.error(e.toString(), e);
-        } catch (CreateException e) {
-            _log.error(e.toString(), e);
-        } catch (SenderException e) {
-            _log.error(e.toString(), e);
-        }
-    }
-
-    private void handleMessage(Message message) throws JMSException, NamingException, RemoteException, SenderException, CreateException {
-        if (message instanceof TextMessage) {
-            TextMessage textMessage = (TextMessage) message;
-            if (_log.isInfoEnabled()) {
-                _log.info("Message received: " + textMessage.getText());
-            }
-            send(textMessage.getText());
-        } else {
-            if (_log.isInfoEnabled()) {
-                _log.info("Unknown message type received: " + message.toString());
-            }
-            send("Unknown message type: " + message.toString());
-        }
-    }
-
-    public void ejbRemove() {
-        if (_log.isInfoEnabled()) {
-            _log.info("SimpleMessageReceiverBean.ejbRemove");
-        }
-    }
-
-    public void setMessageDrivenContext(MessageDrivenContext messageDrivenContext) {
-        if (_log.isInfoEnabled()) {
-            _log.info("SimpleMessageReceiverBean.setMessageDrivenContext");
-        }
-        context = messageDrivenContext;
-    }
-
-    public void ejbCreate() {
-        if (_log.isInfoEnabled()) {
-            _log.info("SimpleMessageReceiverBean.ejbCreate");
-        }
-    }
-
-    private void send(String recMessage) throws NamingException, RemoteException, CreateException, SenderException {
-        sendToEJB(recMessage);
-    }
-
-    private void sendToEJB(String recMessage) throws NamingException, RemoteException, CreateException, SenderException {
-        SenderClient senderClient = new SenderClient(SENDER_NAME);
-        senderClient.sendMessage(recMessage);
-    }   
-}
+package com.panacya.platform.service.bus.mdb;
+
+import com.panacya.platform.service.bus.sender.SenderClient;
+import com.panacya.platform.service.bus.sender.SenderException;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import javax.ejb.CreateException;
+import javax.ejb.MessageDrivenBean;
+import javax.ejb.MessageDrivenContext;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+import javax.jms.TextMessage;
+import javax.naming.NamingException;
+import java.rmi.RemoteException;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+
+public class SimpleMessageReceiverBean implements MessageDrivenBean, MessageListener {
+
+    private static final String SENDER_NAME = "java:comp/env/ejb/Sender";
+    private Log _log = LogFactory.getLog(SimpleMessageReceiverBean.class);
+    private MessageDrivenContext context;
+
+    public SimpleMessageReceiverBean() {
+        if (_log.isInfoEnabled()) {
+            _log.info("SimpleMessageReceiverBean.SimpleMessageReceiverBean");
+        }
+    }
+
+    public void onMessage(Message message)  {
+        if (_log.isInfoEnabled()) {
+            _log.info("SimpleMessageReceiverBean.onMessage");
+        }
+        try {
+            handleMessage(message);
+        } catch (JMSException e) {
+            _log.error(e.toString(), e);
+        } catch (NamingException e) {
+            _log.error(e.toString(), e);
+        } catch (RemoteException e) {
+            _log.error(e.toString(), e);
+        } catch (CreateException e) {
+            _log.error(e.toString(), e);
+        } catch (SenderException e) {
+            _log.error(e.toString(), e);
+        }
+    }
+
+    private void handleMessage(Message message) throws JMSException, NamingException, RemoteException, SenderException, CreateException {
+        if (message instanceof TextMessage) {
+            TextMessage textMessage = (TextMessage) message;
+            if (_log.isInfoEnabled()) {
+                _log.info("Message received: " + textMessage.getText());
+            }
+            send(textMessage.getText());
+        } else {
+            if (_log.isInfoEnabled()) {
+                _log.info("Unknown message type received: " + message.toString());
+            }
+            send("Unknown message type: " + message.toString());
+        }
+    }
+
+    public void ejbRemove() {
+        if (_log.isInfoEnabled()) {
+            _log.info("SimpleMessageReceiverBean.ejbRemove");
+        }
+    }
+
+    public void setMessageDrivenContext(MessageDrivenContext messageDrivenContext) {
+        if (_log.isInfoEnabled()) {
+            _log.info("SimpleMessageReceiverBean.setMessageDrivenContext");
+        }
+        context = messageDrivenContext;
+    }
+
+    public void ejbCreate() {
+        if (_log.isInfoEnabled()) {
+            _log.info("SimpleMessageReceiverBean.ejbCreate");
+        }
+    }
+
+    private void send(String recMessage) throws NamingException, RemoteException, CreateException, SenderException {
+        sendToEJB(recMessage);
+    }
+
+    private void sendToEJB(String recMessage) throws NamingException, RemoteException, CreateException, SenderException {
+        SenderClient senderClient = new SenderClient(SENDER_NAME);
+        senderClient.sendMessage(recMessage);
+    }   
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/mdb/SimpleMessageReceiverBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/Sender.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/Sender.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/Sender.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/Sender.java Tue Feb 21 15:12:56 2006
@@ -1,13 +1,13 @@
-package com.panacya.platform.service.bus.sender;
-
-import javax.ejb.EJBObject;
-import java.rmi.RemoteException;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-
-public interface Sender extends EJBObject {
-
-    public void sendMessage(String message) throws RemoteException, SenderException;
-}
+package com.panacya.platform.service.bus.sender;
+
+import javax.ejb.EJBObject;
+import java.rmi.RemoteException;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+
+public interface Sender extends EJBObject {
+
+    public void sendMessage(String message) throws RemoteException, SenderException;
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/Sender.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderBean.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderBean.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderBean.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderBean.java Tue Feb 21 15:12:56 2006
@@ -1,72 +1,72 @@
-package com.panacya.platform.service.bus.sender;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-import javax.ejb.CreateException;
-import javax.ejb.EJBException;
-import javax.ejb.SessionBean;
-import javax.ejb.SessionContext;
-import javax.jms.JMSException;
-import javax.jms.Queue;
-import javax.jms.QueueConnection;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.QueueSender;
-import javax.jms.QueueSession;
-import javax.jms.TextMessage;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-
-public class SenderBean implements SessionBean {
-    private Log _log = LogFactory.getLog(SenderBean.class);
-    
-    public SenderBean() {
-    }
-
-    public void ejbCreate() throws CreateException {
-    }
-
-    public void setSessionContext(SessionContext sessionContext) throws EJBException {
-    }
-
-    public void ejbRemove() throws EJBException {
-    }
-
-    public void ejbActivate() throws EJBException {
-    }
-
-    public void ejbPassivate() throws EJBException {
-    }
-
-    public void sendMessage(String message) throws SenderException {
-        try {
-            send(message);
-        } catch (NamingException e) {
-            _log.error(e.toString(), e);
-            throw new SenderException(e);
-        } catch (JMSException e) {
-            _log.error(e.toString(), e);
-            throw new SenderException(e);
-        }
-    }
-    
-    private void send(String recMessage) throws NamingException, JMSException {
-        InitialContext initCtx = new InitialContext();
-        QueueConnectionFactory qcf = (QueueConnectionFactory) initCtx.lookup("java:comp/env/jms/MyQueueConnectionFactory");
-        QueueConnection qcon = qcf.createQueueConnection();
-        QueueSession qsession = qcon.createQueueSession(true, 0);
-        Queue q = (Queue) initCtx.lookup("java:comp/env/jms/LogQueue");
-        QueueSender qsender = qsession.createSender(q);
-        TextMessage message = qsession.createTextMessage();
-        message.setText("Message Received: " + recMessage);
-        qsender.send(message);
-        qsender.close();
-        qsession.close();
-        qcon.close();
-    }
-    
-}
+package com.panacya.platform.service.bus.sender;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import javax.ejb.CreateException;
+import javax.ejb.EJBException;
+import javax.ejb.SessionBean;
+import javax.ejb.SessionContext;
+import javax.jms.JMSException;
+import javax.jms.Queue;
+import javax.jms.QueueConnection;
+import javax.jms.QueueConnectionFactory;
+import javax.jms.QueueSender;
+import javax.jms.QueueSession;
+import javax.jms.TextMessage;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+
+public class SenderBean implements SessionBean {
+    private Log _log = LogFactory.getLog(SenderBean.class);
+    
+    public SenderBean() {
+    }
+
+    public void ejbCreate() throws CreateException {
+    }
+
+    public void setSessionContext(SessionContext sessionContext) throws EJBException {
+    }
+
+    public void ejbRemove() throws EJBException {
+    }
+
+    public void ejbActivate() throws EJBException {
+    }
+
+    public void ejbPassivate() throws EJBException {
+    }
+
+    public void sendMessage(String message) throws SenderException {
+        try {
+            send(message);
+        } catch (NamingException e) {
+            _log.error(e.toString(), e);
+            throw new SenderException(e);
+        } catch (JMSException e) {
+            _log.error(e.toString(), e);
+            throw new SenderException(e);
+        }
+    }
+    
+    private void send(String recMessage) throws NamingException, JMSException {
+        InitialContext initCtx = new InitialContext();
+        QueueConnectionFactory qcf = (QueueConnectionFactory) initCtx.lookup("java:comp/env/jms/MyQueueConnectionFactory");
+        QueueConnection qcon = qcf.createQueueConnection();
+        QueueSession qsession = qcon.createQueueSession(true, 0);
+        Queue q = (Queue) initCtx.lookup("java:comp/env/jms/LogQueue");
+        QueueSender qsender = qsession.createSender(q);
+        TextMessage message = qsession.createTextMessage();
+        message.setText("Message Received: " + recMessage);
+        qsender.send(message);
+        qsender.close();
+        qsession.close();
+        qcon.close();
+    }
+    
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderBean.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderClient.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderClient.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderClient.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderClient.java Tue Feb 21 15:12:56 2006
@@ -1,65 +1,65 @@
-package com.panacya.platform.service.bus.sender;
-
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-import javax.ejb.CreateException;
-import javax.naming.Context;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-import javax.rmi.PortableRemoteObject;
-import java.rmi.RemoteException;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-public class SenderClient {
-    private static final Log _log = LogFactory.getLog(SenderClient.class);
-
-    private Sender sender;
-    private String ejbName;
-    
-    public SenderClient(String ejbName) throws NamingException, RemoteException, CreateException {
-        setEjbName(ejbName);
-    }
-
-    public void sendMessage(final String message) throws RemoteException, SenderException {
-        if (_log.isInfoEnabled()) {
-            _log.info("Sending message: " + message);
-        }
-        sender.sendMessage(message);
-        if (_log.isInfoEnabled()) {
-            _log.info("Message sent");
-        }
-    }
-
-    public String getEjbName() {
-        return ejbName;
-    }
-
-    private void setEjbName(final String ejbName) throws NamingException, RemoteException, CreateException {        
-        this.ejbName = ejbName;
-        lookupSender(ejbName);
-    }
-
-    private void lookupSender(final String ejbName) throws NamingException, RemoteException, CreateException {
-        if (_log.isInfoEnabled()) {
-            _log.info("Looking up Sender: " + ejbName);
-        }
-        Context context = new InitialContext();            
-        Object objectRef = context.lookup(ejbName);
-        SenderHome senderHome = (SenderHome) PortableRemoteObject.narrow(objectRef, SenderHome.class);
-        sender = senderHome.create();
-    }
-
-    public static void main(String[] args) {
-
-        try {
-            SenderClient client = new SenderClient("SenderEJB");
-            client.sendMessage("Hello ActiveMQ");
-        } catch (Exception e) {
-            e.printStackTrace();
-        } 
-    }
-
-}
+package com.panacya.platform.service.bus.sender;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import javax.ejb.CreateException;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import javax.rmi.PortableRemoteObject;
+import java.rmi.RemoteException;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+public class SenderClient {
+    private static final Log _log = LogFactory.getLog(SenderClient.class);
+
+    private Sender sender;
+    private String ejbName;
+    
+    public SenderClient(String ejbName) throws NamingException, RemoteException, CreateException {
+        setEjbName(ejbName);
+    }
+
+    public void sendMessage(final String message) throws RemoteException, SenderException {
+        if (_log.isInfoEnabled()) {
+            _log.info("Sending message: " + message);
+        }
+        sender.sendMessage(message);
+        if (_log.isInfoEnabled()) {
+            _log.info("Message sent");
+        }
+    }
+
+    public String getEjbName() {
+        return ejbName;
+    }
+
+    private void setEjbName(final String ejbName) throws NamingException, RemoteException, CreateException {        
+        this.ejbName = ejbName;
+        lookupSender(ejbName);
+    }
+
+    private void lookupSender(final String ejbName) throws NamingException, RemoteException, CreateException {
+        if (_log.isInfoEnabled()) {
+            _log.info("Looking up Sender: " + ejbName);
+        }
+        Context context = new InitialContext();            
+        Object objectRef = context.lookup(ejbName);
+        SenderHome senderHome = (SenderHome) PortableRemoteObject.narrow(objectRef, SenderHome.class);
+        sender = senderHome.create();
+    }
+
+    public static void main(String[] args) {
+
+        try {
+            SenderClient client = new SenderClient("SenderEJB");
+            client.sendMessage("Hello ActiveMQ");
+        } catch (Exception e) {
+            e.printStackTrace();
+        } 
+    }
+
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderClient.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderException.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderException.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderException.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderException.java Tue Feb 21 15:12:56 2006
@@ -1,62 +1,62 @@
-package com.panacya.platform.service.bus.sender;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-public class SenderException extends Exception {
-
-    /**
-     * Constructs a new exception with <code>null</code> as its detail message.
-     * The cause is not initialized, and may subsequently be initialized by a
-     * call to {@link #initCause}.
-     */
-    public SenderException() {
-        super();
-    }
-
-    /**
-     * Constructs a new exception with the specified detail message.  The
-     * cause is not initialized, and may subsequently be initialized by
-     * a call to {@link #initCause}.
-     *
-     * @param message the detail message. The detail message is saved for
-     *                later retrieval by the {@link #getMessage()} method.
-     */
-    public SenderException(final String message) {
-        super(message);
-    }
-
-    /**
-     * Constructs a new exception with the specified detail message and
-     * cause.  <p>Note that the detail message associated with
-     * <code>cause</code> is <i>not</i> automatically incorporated in
-     * this exception's detail message.
-     *
-     * @param message the detail message (which is saved for later retrieval
-     *                by the {@link #getMessage()} method).
-     * @param cause   the cause (which is saved for later retrieval by the
-     *                {@link #getCause()} method).  (A <tt>null</tt> value is
-     *                permitted, and indicates that the cause is nonexistent or
-     *                unknown.)
-     */
-    public SenderException(final String message, final Throwable cause) {
-        super(message, cause);
-    }
-
-    /**
-     * Constructs a new exception with the specified cause and a detail
-     * message of <tt>(cause==null ? null : cause.toString())</tt> (which
-     * typically contains the class and detail message of <tt>cause</tt>).
-     * This constructor is useful for exceptions that are little more than
-     * wrappers for other throwables (for example, {@link
-     * java.security.PrivilegedActionException}).
-     *
-     * @param cause the cause (which is saved for later retrieval by the
-     *              {@link #getCause()} method).  (A <tt>null</tt> value is
-     *              permitted, and indicates that the cause is nonexistent or
-     *              unknown.)
-     */
-    public SenderException(final Throwable cause) {
-        super(cause);
-    }
-}
+package com.panacya.platform.service.bus.sender;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+public class SenderException extends Exception {
+
+    /**
+     * Constructs a new exception with <code>null</code> as its detail message.
+     * The cause is not initialized, and may subsequently be initialized by a
+     * call to {@link #initCause}.
+     */
+    public SenderException() {
+        super();
+    }
+
+    /**
+     * Constructs a new exception with the specified detail message.  The
+     * cause is not initialized, and may subsequently be initialized by
+     * a call to {@link #initCause}.
+     *
+     * @param message the detail message. The detail message is saved for
+     *                later retrieval by the {@link #getMessage()} method.
+     */
+    public SenderException(final String message) {
+        super(message);
+    }
+
+    /**
+     * Constructs a new exception with the specified detail message and
+     * cause.  <p>Note that the detail message associated with
+     * <code>cause</code> is <i>not</i> automatically incorporated in
+     * this exception's detail message.
+     *
+     * @param message the detail message (which is saved for later retrieval
+     *                by the {@link #getMessage()} method).
+     * @param cause   the cause (which is saved for later retrieval by the
+     *                {@link #getCause()} method).  (A <tt>null</tt> value is
+     *                permitted, and indicates that the cause is nonexistent or
+     *                unknown.)
+     */
+    public SenderException(final String message, final Throwable cause) {
+        super(message, cause);
+    }
+
+    /**
+     * Constructs a new exception with the specified cause and a detail
+     * message of <tt>(cause==null ? null : cause.toString())</tt> (which
+     * typically contains the class and detail message of <tt>cause</tt>).
+     * This constructor is useful for exceptions that are little more than
+     * wrappers for other throwables (for example, {@link
+     * java.security.PrivilegedActionException}).
+     *
+     * @param cause the cause (which is saved for later retrieval by the
+     *              {@link #getCause()} method).  (A <tt>null</tt> value is
+     *              permitted, and indicates that the cause is nonexistent or
+     *              unknown.)
+     */
+    public SenderException(final Throwable cause) {
+        super(cause);
+    }
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderException.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderHome.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderHome.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderHome.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderHome.java Tue Feb 21 15:12:56 2006
@@ -1,15 +1,15 @@
-package com.panacya.platform.service.bus.sender;
-
-import javax.ejb.CreateException;
-import javax.ejb.EJBHome;
-import java.rmi.RemoteException;
-
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-
-public interface SenderHome extends EJBHome {
-
-    com.panacya.platform.service.bus.sender.Sender create() throws RemoteException, CreateException;
-}
+package com.panacya.platform.service.bus.sender;
+
+import javax.ejb.CreateException;
+import javax.ejb.EJBHome;
+import java.rmi.RemoteException;
+
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+
+public interface SenderHome extends EJBHome {
+
+    com.panacya.platform.service.bus.sender.Sender create() throws RemoteException, CreateException;
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/main/java/com/panacya/platform/service/bus/sender/SenderHome.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/jboss-test/src/test/java/com/panacya/platform/service/bus/client/ClientArgsTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/jboss-test/src/test/java/com/panacya/platform/service/bus/client/ClientArgsTest.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/jboss-test/src/test/java/com/panacya/platform/service/bus/client/ClientArgsTest.java (original)
+++ incubator/activemq/trunk/systest/jboss-test/src/test/java/com/panacya/platform/service/bus/client/ClientArgsTest.java Tue Feb 21 15:12:56 2006
@@ -1,49 +1,49 @@
-/** 
- * 
- * Copyright 2004 Michael Gaffney
- * 
- * 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 com.panacya.platform.service.bus.client;
-
-import junit.framework.TestCase;
-
-/**
- * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
- */
-public class ClientArgsTest extends TestCase {
-
-    public ClientArgsTest(String name) {
-        super(name);
-    }
-    
-    public void testThreeArgs() {
-        Long timeout = new Long(14999);
-        
-        String[] args = { "send", "topic.testTopic", timeout.toString()};
-        ClientArgs c = new ClientArgs(args);
-        assertEquals(args[0], c.getCommand());
-        assertEquals(args[1], c.getDestination());
-        assertEquals(timeout.longValue(), c.getTimeout());
-    }
-
-    public void testTwoArgs() {        
-        String[] args = { "send", "topic.testTopic"};
-        ClientArgs c = new ClientArgs(args);
-        assertEquals(args[0], c.getCommand());
-        assertEquals(args[1], c.getDestination());
-        assertEquals(-1, c.getTimeout());
-    }
-
-}
+/** 
+ * 
+ * Copyright 2004 Michael Gaffney
+ * 
+ * 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 com.panacya.platform.service.bus.client;
+
+import junit.framework.TestCase;
+
+/**
+ * @author <a href="mailto:michael.gaffney@panacya.com">Michael Gaffney </a>
+ */
+public class ClientArgsTest extends TestCase {
+
+    public ClientArgsTest(String name) {
+        super(name);
+    }
+    
+    public void testThreeArgs() {
+        Long timeout = new Long(14999);
+        
+        String[] args = { "send", "topic.testTopic", timeout.toString()};
+        ClientArgs c = new ClientArgs(args);
+        assertEquals(args[0], c.getCommand());
+        assertEquals(args[1], c.getDestination());
+        assertEquals(timeout.longValue(), c.getTimeout());
+    }
+
+    public void testTwoArgs() {        
+        String[] args = { "send", "topic.testTopic"};
+        ClientArgs c = new ClientArgs(args);
+        assertEquals(args[0], c.getCommand());
+        assertEquals(args[1], c.getDestination());
+        assertEquals(-1, c.getTimeout());
+    }
+
+}

Propchange: incubator/activemq/trunk/systest/jboss-test/src/test/java/com/panacya/platform/service/bus/client/ClientArgsTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/jmscts/src/java/org/exolab/jmscts/activemq/ActiveMQProvider.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueReceiver.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueReceiver.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueReceiver.java (original)
+++ incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueReceiver.java Tue Feb 21 15:12:56 2006
@@ -1,83 +1,83 @@
-package blah;
-
-import java.sql.Timestamp;
-import java.util.Date;
-import java.util.Properties;
-
-import javax.jms.*;
-import javax.naming.*;
-
-public class ActiveMQQueueReceiver {
-    public static void main(String[] args) {
-        Queue queue = null;
-        QueueConnectionFactory queueConnectionFactory = null;
-        QueueConnection queueConnection = null;
-
-        try {
-            Properties props = new Properties();
-            //props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.evermind.server.rmi.RMIInitialContextFactory");
-            //props.setProperty(Context.PROVIDER_URL, "ormi://10.1.0.99:3202/default");
-            //props.setProperty(Context.SECURITY_PRINCIPAL, "dan");
-            //props.setProperty(Context.SECURITY_CREDENTIALS, "abc123");
-
-            props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.activemq.jndi.ActiveMQInitialContextFactory");
-            props.setProperty(Context.PROVIDER_URL, "tcp://hostname:61616");
-            props.setProperty("queue.BlahQueue", "example.BlahQueue");
-
-            // use the following if you with to make the receiver a broker
-            //props.setProperty("useEmbeddedBroker", "true");
-
-            Context jndiContext = new InitialContext(props);
-
-            //queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("jms/QueueConnectionFactory");
-            //queue = (Queue) jndiContext.lookup("jms/demoQueue");
-            queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory");
-            queue = (Queue) jndiContext.lookup("BlahQueue");
-        }
-        catch (NamingException e) {
-            System.out.println("---------------------------ERROR-----------------------------");
-            e.printStackTrace();
-            System.exit(-1);
-        }
-
-        try {
-            queueConnection = queueConnectionFactory.createQueueConnection();
-            QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
-            QueueReceiver queueReceiver = queueSession.createReceiver(queue);
-            queueConnection.start();
-
-            //while (true)
-            //{
-            System.out.println("Starting to receive");
-
-            TextMessage message = (TextMessage) queueReceiver.receive(10000);
-
-            if (message != null) {
-                Date timestamp = new Date(message.getJMSTimestamp());
-                System.out.println("Blah:       " + message.getStringProperty("Blah"));
-                System.out.println("Timestamp:  " + timestamp);
-                System.out.println("Payload:    " + message.getText());
-            }
-            else {
-                System.out.println("NO MESSAGES");
-            }
-            System.out.println();
-
-            //Thread.sleep(10000);
-            //}
-        }
-        catch (Exception e) {
-            System.out.println("SOMETHING WENT WRONG WHILE CONSUMING");
-            e.printStackTrace();
-        }
-        finally {
-            if (queueConnection != null) {
-                try {
-                    queueConnection.close();
-                }
-                catch (Exception ignored) {
-                }
-            }
-        }
-    }
-}
+package blah;
+
+import java.sql.Timestamp;
+import java.util.Date;
+import java.util.Properties;
+
+import javax.jms.*;
+import javax.naming.*;
+
+public class ActiveMQQueueReceiver {
+    public static void main(String[] args) {
+        Queue queue = null;
+        QueueConnectionFactory queueConnectionFactory = null;
+        QueueConnection queueConnection = null;
+
+        try {
+            Properties props = new Properties();
+            //props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.evermind.server.rmi.RMIInitialContextFactory");
+            //props.setProperty(Context.PROVIDER_URL, "ormi://10.1.0.99:3202/default");
+            //props.setProperty(Context.SECURITY_PRINCIPAL, "dan");
+            //props.setProperty(Context.SECURITY_CREDENTIALS, "abc123");
+
+            props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.activemq.jndi.ActiveMQInitialContextFactory");
+            props.setProperty(Context.PROVIDER_URL, "tcp://hostname:61616");
+            props.setProperty("queue.BlahQueue", "example.BlahQueue");
+
+            // use the following if you with to make the receiver a broker
+            //props.setProperty("useEmbeddedBroker", "true");
+
+            Context jndiContext = new InitialContext(props);
+
+            //queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("jms/QueueConnectionFactory");
+            //queue = (Queue) jndiContext.lookup("jms/demoQueue");
+            queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory");
+            queue = (Queue) jndiContext.lookup("BlahQueue");
+        }
+        catch (NamingException e) {
+            System.out.println("---------------------------ERROR-----------------------------");
+            e.printStackTrace();
+            System.exit(-1);
+        }
+
+        try {
+            queueConnection = queueConnectionFactory.createQueueConnection();
+            QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
+            QueueReceiver queueReceiver = queueSession.createReceiver(queue);
+            queueConnection.start();
+
+            //while (true)
+            //{
+            System.out.println("Starting to receive");
+
+            TextMessage message = (TextMessage) queueReceiver.receive(10000);
+
+            if (message != null) {
+                Date timestamp = new Date(message.getJMSTimestamp());
+                System.out.println("Blah:       " + message.getStringProperty("Blah"));
+                System.out.println("Timestamp:  " + timestamp);
+                System.out.println("Payload:    " + message.getText());
+            }
+            else {
+                System.out.println("NO MESSAGES");
+            }
+            System.out.println();
+
+            //Thread.sleep(10000);
+            //}
+        }
+        catch (Exception e) {
+            System.out.println("SOMETHING WENT WRONG WHILE CONSUMING");
+            e.printStackTrace();
+        }
+        finally {
+            if (queueConnection != null) {
+                try {
+                    queueConnection.close();
+                }
+                catch (Exception ignored) {
+                }
+            }
+        }
+    }
+}

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueReceiver.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueSender.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueSender.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueSender.java (original)
+++ incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueSender.java Tue Feb 21 15:12:56 2006
@@ -1,80 +1,80 @@
-package blah;
-
-import java.util.Properties;
-
-import javax.jms.*;
-import javax.naming.*;
-
-public class ActiveMQQueueSender
-{
-   public static void main(String[] args)
-   {
-      String msg = args.length < 1 ? "This is the default message" : args[0];
-
-      Queue queue = null;
-      QueueConnectionFactory queueConnectionFactory = null;
-      QueueConnection queueConnection = null;
-
-      try
-      {
-         Properties props = new Properties();
-         //props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.evermind.server.rmi.RMIInitialContextFactory");
-         //props.setProperty(Context.PROVIDER_URL, "ormi://10.1.0.99:3202/default");
-         //props.setProperty(Context.SECURITY_PRINCIPAL, "dan");
-         //props.setProperty(Context.SECURITY_CREDENTIALS, "abc123");
-         
-         props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.activemq.jndi.ActiveMQInitialContextFactory");
-         props.setProperty(Context.PROVIDER_URL, "tcp://hostname:61616");
-         props.setProperty("queue.BlahQueue", "example.BlahQueue");
-
-         Context jndiContext = new InitialContext(props);
-         
-         //queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("jms/QueueConnectionFactory");
-         //queue = (Queue) jndiContext.lookup("jms/demoQueue");
-
-         queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory");
-         queue = (Queue) jndiContext.lookup("BlahQueue");
-
-      }
-      catch (NamingException e)
-      {
-         System.out.println("---------------------------ERROR-----------------------------");
-         e.printStackTrace();
-         System.exit(-1);
-      }
-
-      try
-      {
-         queueConnection = queueConnectionFactory.createQueueConnection();
-         QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
-         QueueSender queueSender = queueSession.createSender(queue);
-         //queueSender.setDeliveryMode(DeliveryMode.PERSISTENT);
-         //queueSender.setTimeToLive(1000*60*60);
-         TextMessage message = queueSession.createTextMessage();
-
-         message.setText(msg);
-         message.setStringProperty("Blah", "Hello!");
-
-         queueSender.send(message);
-         System.out.println("Message sent");
-      }
-      catch (JMSException e)
-      {
-         System.out.println("SOMETHING WENT WRONG WHILE SENDING");
-         e.printStackTrace();
-      }
-      finally
-      {
-         if (queueConnection != null)
-         {
-            try
-            {
-               queueConnection.close();
-            }
-            catch (Exception ignored)
-            {
-            }
-         }
-      }
-   }
-}
+package blah;
+
+import java.util.Properties;
+
+import javax.jms.*;
+import javax.naming.*;
+
+public class ActiveMQQueueSender
+{
+   public static void main(String[] args)
+   {
+      String msg = args.length < 1 ? "This is the default message" : args[0];
+
+      Queue queue = null;
+      QueueConnectionFactory queueConnectionFactory = null;
+      QueueConnection queueConnection = null;
+
+      try
+      {
+         Properties props = new Properties();
+         //props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.evermind.server.rmi.RMIInitialContextFactory");
+         //props.setProperty(Context.PROVIDER_URL, "ormi://10.1.0.99:3202/default");
+         //props.setProperty(Context.SECURITY_PRINCIPAL, "dan");
+         //props.setProperty(Context.SECURITY_CREDENTIALS, "abc123");
+         
+         props.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.activemq.jndi.ActiveMQInitialContextFactory");
+         props.setProperty(Context.PROVIDER_URL, "tcp://hostname:61616");
+         props.setProperty("queue.BlahQueue", "example.BlahQueue");
+
+         Context jndiContext = new InitialContext(props);
+         
+         //queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("jms/QueueConnectionFactory");
+         //queue = (Queue) jndiContext.lookup("jms/demoQueue");
+
+         queueConnectionFactory = (QueueConnectionFactory) jndiContext.lookup("QueueConnectionFactory");
+         queue = (Queue) jndiContext.lookup("BlahQueue");
+
+      }
+      catch (NamingException e)
+      {
+         System.out.println("---------------------------ERROR-----------------------------");
+         e.printStackTrace();
+         System.exit(-1);
+      }
+
+      try
+      {
+         queueConnection = queueConnectionFactory.createQueueConnection();
+         QueueSession queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
+         QueueSender queueSender = queueSession.createSender(queue);
+         //queueSender.setDeliveryMode(DeliveryMode.PERSISTENT);
+         //queueSender.setTimeToLive(1000*60*60);
+         TextMessage message = queueSession.createTextMessage();
+
+         message.setText(msg);
+         message.setStringProperty("Blah", "Hello!");
+
+         queueSender.send(message);
+         System.out.println("Message sent");
+      }
+      catch (JMSException e)
+      {
+         System.out.println("SOMETHING WENT WRONG WHILE SENDING");
+         e.printStackTrace();
+      }
+      finally
+      {
+         if (queueConnection != null)
+         {
+            try
+            {
+               queueConnection.close();
+            }
+            catch (Exception ignored)
+            {
+            }
+         }
+      }
+   }
+}

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/ActiveMQQueueSender.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/AvailableConsumerTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/BecksNetworkTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/EmbeddedRemoteConnectorTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/EmbeddedRemoteConnectorTest.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/EmbeddedRemoteConnectorTest.java (original)
+++ incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/EmbeddedRemoteConnectorTest.java Tue Feb 21 15:12:56 2006
@@ -1,178 +1,178 @@
-/**
- *
- * Copyright 2004 Protique Ltd
- *
- * 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.activemq.usecases;
-
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.broker.BrokerContainer;
-import org.activemq.broker.impl.BrokerContainerImpl;
-import junit.framework.TestCase;
-
-
-import org.activemq.spring.SpringBrokerContainerFactory;
-import org.springframework.core.io.ClassPathResource;
-
-import javax.jms.JMSException;
-import javax.jms.Session;
-import javax.jms.Connection;
-import javax.jms.DeliveryMode;
-import javax.jms.MessageProducer;
-import javax.jms.MessageConsumer;
-import javax.jms.Destination;
-import javax.jms.TextMessage;
-import javax.jms.Message;
-
-import org.activemq.io.impl.DefaultWireFormat;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.jdbc.JDBCPersistenceAdapter;
-import org.apache.derby.jdbc.EmbeddedDataSource;
-
-/**
- * @version $Revision: 1.1.1.1 $
- */
-public class EmbeddedRemoteConnectorTest extends TestCase{
-    BrokerContainer receiveBroker;
-    String subject = "TOOL.DEFAULT";
-     int messageCount = 10;
-     boolean init = false;
-
-
-
-    protected ActiveMQConnectionFactory createReceiverConnectionFactory() throws JMSException {
-        receiveBroker = new BrokerContainerImpl("receiver");
-        receiveBroker.addConnector("tcp://localhost:61616");
-        receiveBroker.setPersistenceAdapter(createPersistenceAdapter());
-        receiveBroker.start();
-
-        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(receiveBroker, "tcp://localhost:61616");
-
-        return factory;
-    }
-
-    protected ActiveMQConnectionFactory createEmbeddedRemoteBrokerConnectionFactory() throws JMSException {
-        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
-        connectionFactory.setUseEmbeddedBroker(true);
-        connectionFactory.setBrokerContainerFactory(new SpringBrokerContainerFactory(new ClassPathResource("org/activemq/usecases/EmbeddedRemoteConnector.xml")));
-
-        return connectionFactory;
-    }
-
-
-
-
-    public void testSendFromEmbeddedRemote() throws Exception {
-
-        ActiveMQConnectionFactory embeddedRemoteFactory = createEmbeddedRemoteBrokerConnectionFactory();
-        Connection conn = embeddedRemoteFactory.createConnection();
-        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        Destination destination = session.createQueue(subject);
-        MessageProducer producer = session.createProducer(destination);
-        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
-
-        for (int i = 0; i < messageCount; i++) {
-           TextMessage message = session.createTextMessage("Message : " +i);
-           producer.send(message);
-           System.out.println("Sending   " + message.getText());
-        }
-
-
-
-    }
-
-    public void testReceiver() throws Exception {
-        ActiveMQConnectionFactory receiveFactory = createReceiverConnectionFactory();
-
-        Connection conn = receiveFactory.createConnection();
-        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        Destination destination = session.createQueue(subject);
-        MessageConsumer consumer = session.createConsumer(destination);
-        conn.start();
-
-        
-        int counter =0;
-        
-        for (int i = 0; i < messageCount; i++) {
-            System.out.println("Before receive");
-            Message message = consumer.receive(10000);
-            try {
-                if (message instanceof TextMessage) {
-                   TextMessage txtMsg = (TextMessage) message;
-                   System.out.println("Received : " + txtMsg.getText());
-
-                   //increment counter only when a message is received
-                   if(txtMsg.getText()!=null && txtMsg.getText().length()==0) {
-                       counter++;
-                   }
-
-
-                }
-            }
-            catch (Exception e) {
-                e.printStackTrace();
-            }
-
-
-        }
-        
-        consumer.close();
-        session.close();
-        conn.close();
-        
-        assertTrue("No messages were received",counter==messageCount );
-
-    }
-
-
-
-    protected void tearDown() throws Exception {
-
-        if (receiveBroker != null) {
-            receiveBroker.stop();
-        }
-    }
-
-
-
-
-
-
-    /**
-     * Returns the persistence adapter.
-     * Sets up the testing database to be used when the messages are persistent.
-     * It attempts to recreate the tables everytime the test is executed.
-     *
-     * @return PersistenceAdapter - persistence adapter.
-     */
-    protected PersistenceAdapter createPersistenceAdapter() {
-        EmbeddedDataSource ds = new EmbeddedDataSource();
-        ds.setDatabaseName("testdb");
-        if (!init) {
-            ds.setCreateDatabase("create");
-        }
-
-        JDBCPersistenceAdapter persistenceAdapter = new JDBCPersistenceAdapter(ds, new DefaultWireFormat());
-
-        if (!init) {
-            persistenceAdapter.setDropTablesOnStartup(true);
-        }
-
-        init = true;
-
-        return persistenceAdapter;
-    }    
-
-}
+/**
+ *
+ * Copyright 2004 Protique Ltd
+ *
+ * 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.activemq.usecases;
+
+import org.activemq.ActiveMQConnectionFactory;
+import org.activemq.broker.BrokerContainer;
+import org.activemq.broker.impl.BrokerContainerImpl;
+import junit.framework.TestCase;
+
+
+import org.activemq.spring.SpringBrokerContainerFactory;
+import org.springframework.core.io.ClassPathResource;
+
+import javax.jms.JMSException;
+import javax.jms.Session;
+import javax.jms.Connection;
+import javax.jms.DeliveryMode;
+import javax.jms.MessageProducer;
+import javax.jms.MessageConsumer;
+import javax.jms.Destination;
+import javax.jms.TextMessage;
+import javax.jms.Message;
+
+import org.activemq.io.impl.DefaultWireFormat;
+import org.activemq.store.PersistenceAdapter;
+import org.activemq.store.jdbc.JDBCPersistenceAdapter;
+import org.apache.derby.jdbc.EmbeddedDataSource;
+
+/**
+ * @version $Revision: 1.1.1.1 $
+ */
+public class EmbeddedRemoteConnectorTest extends TestCase{
+    BrokerContainer receiveBroker;
+    String subject = "TOOL.DEFAULT";
+     int messageCount = 10;
+     boolean init = false;
+
+
+
+    protected ActiveMQConnectionFactory createReceiverConnectionFactory() throws JMSException {
+        receiveBroker = new BrokerContainerImpl("receiver");
+        receiveBroker.addConnector("tcp://localhost:61616");
+        receiveBroker.setPersistenceAdapter(createPersistenceAdapter());
+        receiveBroker.start();
+
+        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(receiveBroker, "tcp://localhost:61616");
+
+        return factory;
+    }
+
+    protected ActiveMQConnectionFactory createEmbeddedRemoteBrokerConnectionFactory() throws JMSException {
+        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
+        connectionFactory.setUseEmbeddedBroker(true);
+        connectionFactory.setBrokerContainerFactory(new SpringBrokerContainerFactory(new ClassPathResource("org/activemq/usecases/EmbeddedRemoteConnector.xml")));
+
+        return connectionFactory;
+    }
+
+
+
+
+    public void testSendFromEmbeddedRemote() throws Exception {
+
+        ActiveMQConnectionFactory embeddedRemoteFactory = createEmbeddedRemoteBrokerConnectionFactory();
+        Connection conn = embeddedRemoteFactory.createConnection();
+        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Destination destination = session.createQueue(subject);
+        MessageProducer producer = session.createProducer(destination);
+        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+
+        for (int i = 0; i < messageCount; i++) {
+           TextMessage message = session.createTextMessage("Message : " +i);
+           producer.send(message);
+           System.out.println("Sending   " + message.getText());
+        }
+
+
+
+    }
+
+    public void testReceiver() throws Exception {
+        ActiveMQConnectionFactory receiveFactory = createReceiverConnectionFactory();
+
+        Connection conn = receiveFactory.createConnection();
+        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Destination destination = session.createQueue(subject);
+        MessageConsumer consumer = session.createConsumer(destination);
+        conn.start();
+
+        
+        int counter =0;
+        
+        for (int i = 0; i < messageCount; i++) {
+            System.out.println("Before receive");
+            Message message = consumer.receive(10000);
+            try {
+                if (message instanceof TextMessage) {
+                   TextMessage txtMsg = (TextMessage) message;
+                   System.out.println("Received : " + txtMsg.getText());
+
+                   //increment counter only when a message is received
+                   if(txtMsg.getText()!=null && txtMsg.getText().length()==0) {
+                       counter++;
+                   }
+
+
+                }
+            }
+            catch (Exception e) {
+                e.printStackTrace();
+            }
+
+
+        }
+        
+        consumer.close();
+        session.close();
+        conn.close();
+        
+        assertTrue("No messages were received",counter==messageCount );
+
+    }
+
+
+
+    protected void tearDown() throws Exception {
+
+        if (receiveBroker != null) {
+            receiveBroker.stop();
+        }
+    }
+
+
+
+
+
+
+    /**
+     * Returns the persistence adapter.
+     * Sets up the testing database to be used when the messages are persistent.
+     * It attempts to recreate the tables everytime the test is executed.
+     *
+     * @return PersistenceAdapter - persistence adapter.
+     */
+    protected PersistenceAdapter createPersistenceAdapter() {
+        EmbeddedDataSource ds = new EmbeddedDataSource();
+        ds.setDatabaseName("testdb");
+        if (!init) {
+            ds.setCreateDatabase("create");
+        }
+
+        JDBCPersistenceAdapter persistenceAdapter = new JDBCPersistenceAdapter(ds, new DefaultWireFormat());
+
+        if (!init) {
+            persistenceAdapter.setDropTablesOnStartup(true);
+        }
+
+        init = true;
+
+        return persistenceAdapter;
+    }    
+
+}

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/EmbeddedRemoteConnectorTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/lars/Server.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/lars/ServerLoader.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/rest/RESTLoadTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/rest/TestConsumerThread.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/systest/usecases/src/test/org/activemq/usecases/rest/TestProducerThread.java
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message