Initial

Author: eduard93

.idea/vcs.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="library" name="com.rabbitmq:amqp-client:5.0.0" level="project" />
+  </component>
+</module>

RabbitMQjava.iml

@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Main-Class: com.isc.rabbitmq.Wrapper
+

src/META-INF/MANIFEST.MF

@@ -0,0 +1,100 @@
+package isc.rabbitmq;
+
+import com.rabbitmq.client.*;
+
+import java.io.IOException;
+
+
+/**
+ * Created by eduard on 06.10.2017.
+ */
+public class API {
+    private final Channel _channel;
+
+    private final String _queue;
+
+    private final Connection _connection;
+
+    public API(String host, int port, String user, String pass, String virtualHost, String queue)  throws Exception {
+        ConnectionFactory factory = new ConnectionFactory();
+        factory.setHost(host);
+        factory.setPort(port);
+        factory.setUsername(user);
+        factory.setPassword(pass);
+        factory.setVirtualHost(virtualHost);
+
+
+        _connection = factory.newConnection();
+        _channel = _connection.createChannel();
+        _channel.queueDeclare(queue, false, false, false, null);
+        _queue = queue;
+    }
+
+    public String[] readMessageStream(byte[] msg) throws Exception {
+        String[] result = new String[15];
+
+        GetResponse response = readMessage(result);
+        if (response == null) {
+            // No message retrieved.
+        } else {
+            System.arraycopy(response.getBody(),0,msg,0, response.getBody().length);
+        }
+        return result;
+    }
+
+    public void sendMessage(byte[] msg) throws Exception {
+        sendMessageToQueue(_queue, msg);
+    }
+
+    public void sendMessageToQueue(String queue, byte[] msg) throws Exception {
+        _channel.basicPublish("", queue, null, msg);
+    }
+
+    public String[] readMessageString() throws Exception {
+        String[] result = new String[16];
+
+        GetResponse response = readMessage(result);
+        if (response == null) {
+            // No message retrieved.
+        } else {
+            result[15] = new String(response.getBody());
+        }
+        return result;
+    }
+
+    /*
+    Get message and fill basic array props
+     */
+    private GetResponse readMessage(String[] msg) throws IOException {
+        boolean autoAck = true;
+        GetResponse response = _channel.basicGet(_queue, autoAck);
+        if (response == null) {
+            // No message retrieved.
+        } else {
+            AMQP.BasicProperties props = response.getProps();
+            msg[0] =  Integer.toString(response.getBody().length);
+            msg[1] =  Integer.toString(response.getMessageCount());
+            msg[2] = props.getContentType();
+            msg[3] = props.getContentEncoding();
+            msg[4] = props.getCorrelationId();
+            msg[5] = props.getReplyTo();
+            msg[6] = props.getExpiration();
+            msg[7] = props.getMessageId();
+            msg[8] = props.getType();
+            msg[9] = props.getUserId();
+            msg[10] = props.getAppId();
+            msg[11] = props.getClusterId();
+            msg[12] = props.getDeliveryMode() != null ? Integer.toString(props.getDeliveryMode()) : null;
+            msg[13] = props.getPriority() != null ? Integer.toString(props.getPriority()) : null;
+            msg[14] = props.getTimestamp() != null ? props.getTimestamp().toString() : null;
+        }
+        return response;
+
+    }
+
+    public void close()throws Exception {
+        _channel.close();
+        _connection.close();
+    }
+
+}