在IBM中推送消息时发生错误。
在IBM中推送消息时发生错误。
提问于 2016-06-20 12:06:06
我正在使用。
我试图通过java程序在IBM中推送一条消息，我的连接很好。当我运行程序并检查本地主机时，它显示客户端已连接，但3-4秒后，它被断开连接，异常被抛出控制台。
以下是我的错误日志：
Problem with subscribe request: amqp:unauthorized-access: AMQXR0042E: A subscribe request was not authorized for channel PlainText received from 127.0.0.1. AMQXR0004E: MQSeries verb=SPISubscribe(String) returned cc=2(int) MQCC_FAILED rc=2035(int) MQRC_NOT_AUTHORIZED回答 1
Stack Overflow用户
回答已采纳
发布于 2016-06-22 04:47:37
我有一个示例代码，您可以通过它在IBM中推送消息。
package com.Queue;
import com.ibm.mqlight.api.ClientOptions;
import com.ibm.mqlight.api.Delivery;
import com.ibm.mqlight.api.DestinationAdapter;
import com.ibm.mqlight.api.NonBlockingClient;
import com.ibm.mqlight.api.NonBlockingClientAdapter;
import com.ibm.mqlight.api.StringDelivery;
public class SendReceive2
{
public static void main(String[] cmdline)
{
ClientOptions clientOpts = ClientOptions.builder().setCredentials("ad", "jms123").build();
NonBlockingClient.create("amqp://localhost", clientOpts, new NonBlockingClientAdapter<Void>()
{
public void onStarted(NonBlockingClient client, Void context)
{
client.subscribe("JmsQueue", new DestinationAdapter<Void>()
{
public void onMessage(NonBlockingClient client, Void context, Delivery delivery)
{
if (delivery.getType() == Delivery.Type.STRING)
System.out.println(((StringDelivery)delivery).getData());
}
}, null, null);
}
}, null);
NonBlockingClient.create("amqp://localhost", clientOpts, new NonBlockingClientAdapter<Void>()
{
public void onStarted(NonBlockingClient client, Void context)
{
client.send("JmsQueue", "Jms Queue is Formed!", null);
}
}, null);
}//main
}//class试试看，它在我的情况下有效
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/37922173
复制相关文章
相似问题
腾讯云开发者
