Hallo Leute,
ich muss eine Verbindung zu einem RabbitMQ-Server aufbauen. Leider bekomme ich immer eine NullPointerException zurück. Ich kann leider keinen Fehler finden, mein Codeausschnitt stammt von der RabbitMQ-Seite.
Ich hoffe ihr könnt mir helfen.
...so erzeuge ich dann das Objekt:
Die Zugangdaten habe ich schon zig Male überprüft
ich muss eine Verbindung zu einem RabbitMQ-Server aufbauen. Leider bekomme ich immer eine NullPointerException zurück. Ich kann leider keinen Fehler finden, mein Codeausschnitt stammt von der RabbitMQ-Seite.
Ich hoffe ihr könnt mir helfen.
Java:
public class HostConnection implements Serializable{
private String EXCHANGE_NAME = "someExchanget";
private String HOST_QUEUE_NAME = "someQueue";
private String HOST_NAME = "**************";
private String HOST_UNAME = "********";
private String HOST_PWD = "*******";
private int HOST_PORT = xxxxx;
private Connection conn;
private Channel channel;
private ConnectionFactory factory;
public HostConnection(){
this.factory = new ConnectionFactory();
factory.setHost(HOST_NAME);
factory.setPort(HOST_PORT);
factory.setUsername(HOST_UNAME);
factory.setPassword(HOST_PWD);
try {
this.conn = factory.newConnection();
} catch (IOException ex) {
System.out.println("Connection to Server can't be established!");
}
try {
this.channel = conn.createChannel();
} catch (IOException ex) {
System.out.println("Can't create Channel");
}
try {
channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
} catch (IOException ex) {
System.out.println("Can't declare Exchange");
}
try {
channel.queueDeclare(HOST_QUEUE_NAME, true, true, false, null);
} catch (IOException ex) {
System.out.println("Can't declare QUEUE");
}
try {
channel.queueBind(HOST_QUEUE_NAME, EXCHANGE_NAME, "");
} catch (IOException ex) {
System.out.println("Can't bind QUEUE");
}
}...so erzeuge ich dann das Objekt:
Java:
HostConnection hconn = new HostConnection();Die Zugangdaten habe ich schon zig Male überprüft
