jjzjj

message-queue

全部标签

java - API 网关自定义授权方 : Control error message and code

我的网关API有一个自定义授权方。我读过很多关于如何自定义在身份验证或授权错误时返回给最终用户的错误消息和代码的文章。Thisoneseemedthemostuseful.问题是API网关的行为与记录不符。我的自定义授权器实现(python):deflambda_handler(event,context):raiseException('theskyisfalling!')当我使用curl调用API时:kash@Laptop$date;curl-i-XGET-H"Authorization:Bearer1234abcd`date+%s`"https://xxxx.execute-ap

java - 如何找到 horneq 队列长度

我正在使用Hornetq2.0,我不明白我怎么知道此刻队列中有多少消息。这是一个非常有用的功能,因此我可以在运行时知道我的消费者是否足够快地消费消息。我没有使用JMSapi,而是使用高度优化的核心API。获取队列中消息数量的正确(最快)方法是什么?我找到了2种方法,但不知道什么是正确的方法。publicintsize(){ClientSessionsession;try{session=sf.createSession(false,false,false);ClientRequestorrequestor=newClientRequestor(session,"hornetq.mana

java - jboss.jms 和 jboss.mq 有什么区别?

类org.jboss.jms.server.destination.QueueService和org.jboss.mq.server.jmx.Queue有什么区别? 最佳答案 org.jboss.jms.server.destination.QueueService是JBossMessaging的一部分,它是JBoss的新JMS实现,作为JBossAppServer版本5及更高版本(或JBossEAP4.3或更高版本)的一部分提供org.jboss.mq.server.jmx.Queue是JBossMQ的一部分,它是JBoss旧的(

java - MessageConsumer 不消费消息

我的应用程序在Jboss7.1.1上运行。我有一个每分钟运行一次的调度程序,需要检查DLQ中是否有消息并在数据库中进行一些更新。我编写了一个消息消费者来监听预定义的自定义DLQ。问题是我可以看到自定义DLQ中有消息,但consumer.receiveNoWait()总是返回null。下面是创建消费者的代码:/*thisisrunningfineandcreatingtheconsumer*/publicDestinationHandlerImpl(ConnectionFactoryconnectionFactory,Destinationdestination,booleanuseTr

java - 无法使用 Google App Engine (GAE) 连接到 Google Cloud Messaging (GCM) 服务器

我正在尝试为我的应用程序设置谷歌云消息传递,并且我正在为我的服务器使用GoogleAppEngine。我有我的APIkey,但我似乎无法连接到谷歌云消息服务器。这是我的代码。HttpClientclient=newDefaultHttpClient();HttpPostpost=newHttpPost("https://android.googleapis.com/gcm/send");try{ListnameValuePairs=newArrayList(2);nameValuePairs.add(newBasicNameValuePair("registration_id",reg

java - 如何模拟难以实例化的类 (javax.mail.Message)?

我想在我的下一个项目中使用junit测试,但我不确定我应该使用几个模拟包中的哪一个。我还阅读了一些教程,但没有找到如何解决下面概述的特定问题的信息。也许该功能在我checkout的软件包中不可用。这就是问题所在:我想编写一个遍历List的电子邮件过滤器类并按主题、日期、发件人、收件人等过滤电子邮件。要测试的代码如下所示:publicListdoFilter(ListmessageList){ListnewList=newArrayList(messageList.size());try{for(Messagemessage:messageList){if(start!=null){Da

java - Java/Grails 环境中用户通知的最佳解决方案架构?

我正在使用Grails构建一个社区网站,我想实现与stackoverflow.com完全一样的用户通知。例如,用户将在他返回网站时通过电子邮件或邮箱收到新事件通知(“您有新评论”、“您最喜欢的评论之一已更改”...)。我想这是一个常见问题,我想听听您对在Grails领域中实现后端有什么简单的解决方案建议。例如,Java消息服务是否是为此推荐的解决方案?谢谢。 最佳答案 恕我直言,没有。Java消息服务基本上是执行异步或排队操作。您只需要一个用户消息系统和通知。我不知道有任何插件可以开箱即用。我建议您使用markAsRead标志实现您

java - 如何解决 Message payload is of type : BufferInputStream Exception in Mule

我已经在转换为字节数组,但我不断收到此错误:ERROR2015-02-2511:12:30,517[[ESR].HTTP_Request_Listener.worker.01]org.mule.exception.DefaultMessagingExceptionStrategy:********************************************************************************Message:Responsecode400mappedasfailure.Messagepayloadisoftype:BufferInputSt

java - 如何在登录屏幕上重定向 Spring 安全并发 session 控制 'message'?

我有一个Web应用程序,我在其中使用了Spring框架。对于并发session控制,我使用了spring功能,一旦该用户登录到另一个session,他/她之前的session将过期,只有1个登录session将为该用户维护。现在在这种情况下,我收到此消息“此session已过期(可能是由于以同一用户身份尝试多次并发登录)。”但我在浏览器的完整白页上收到此消息。我希望这条消息只出现在我的登录屏幕上。这是我的springsecurityxml的一部分,我在其中为用户处理了并发session。任何专门用于自定义此消息并将此消息重定向到所需Web应用程序页面的链接将不胜感激。提前致谢。

java - 网络 NIO : Read received messages

我正在使用Java中的NettyNIO开发客户端和服务器通信系统。我的代码可以找到inthefollowingrepository.目前我有一台服务器和两个客户端,我正在将信息从服务器发送到客户端,反之亦然。我想弄清楚的是,当我从第一个客户端接收到服务器的消息时,我如何将该消息发送到第二个客户端(以及从客户端2到客户端1的相反方向)。如何向特定客户端发送消息?我注意到我的问题是由于我尝试从服务器发送消息的方式引起的。我在serverHandler中的代码如下:for(Channelch:channels1){responseData.setIntValue(channels1.size