Tagged Questions

0
votes
0answers
9 views

file based queuing service in java for ipc

I want a file based queuing service which can store text data, as example I have two separate process 'A' and 'B'. 'A' reading data from serial port and 'B' is sending data over internet to a host. ...
1
vote
0answers
26 views

Externalizing resource adapter configs from standalone.xml in Jboss-as 7.1.1

I'm using Jboss-as 7.1.1 I have configured the resource adapter as below in the standalone.xml file. This basically is the configuration for a outbound queue using Websphere MQ and it works fine. ...
0
votes
1answer
39 views

Design decision for text message queueing implementation

I have a scenario where using certain text message gateway I receive incoming messages via GET within the servlet, compose the reply message, store it in database with id key and then just send it out ...
0
votes
1answer
16 views

APNS and message queue

How can I set up a queue on a Java side Server to invoke the APNS only every 5 min. So that I do not overload my user with constant mail Push Notifications, but rather update the App only every 5 min. ...
0
votes
1answer
43 views

Syntax for selecting messages by Jms ID

What is the correct syntax for selecting messages based on their corresponding JMS ID? Currently I use: String selector = "JMSMessageID='ID:305:1:5:1:1'"; messageConsumer = ...
-1
votes
0answers
23 views

Messages from JMS queue to sqs queue [closed]

i have to write a code that receives messages from a JMS Queue and send to an sqs queue. i have no idea gow to do that. can anybody give me some advices?
0
votes
0answers
66 views

“Aggregate” Messages from two Queues in ActiveMQ

I need to implement a Coordination Problem in JMS: -) There is a limited number of tables -) Groups are coming to the Pizzeria and wait for a Waiter to seat them at a Table -) There can be multiple ...
0
votes
1answer
37 views

Apache Camel - sending a Properties object over the route

I have a Properties object that contains all the fields to be sent as a message to consumer's queue. What is the recommended way to pass Properties-like objects? Shall I set a header for every key in ...
0
votes
1answer
35 views

Delaying multiple calls to java webservice

I get around 20 calls to my webservice every hour but they all arrive at the same time. For each request I get I need to call a telnet server and execute some commands. The problem is that the ...
0
votes
1answer
74 views

How to Implement Request Reply pattern

I am trying to implement the request-reply pattern using Camel, Spring and ActiveMQ. What I need to do is reading CSV file line-by-line. Then for every line: Construct request based on line values ...
1
vote
2answers
88 views

ESB/Message Queue quick start

I need to implement a demo system for prove of concept. Basically, the system description can be reduced to 2 modules: Module 1 sends requests Module 2 picks them up, processes and sends the ...
0
votes
1answer
82 views

Add manually mappedName in Message Driven Bean at runtime

I need to make simple Message Driven Bean that will listen on dynamically added queue locataions. I have tried few ways to implement this, but none of them worked. I have appplication that uses esb ...
0
votes
0answers
34 views

ActiveMQ : Local transaction had not been commited. Commiting now

In ActiveMQ, while the queue is processing the messages, Lets say if the queue has got 100 messages, it has dequeued 10 messages and then immediately in one second it has dequeued the remaining ...
0
votes
1answer
35 views

page.db size in SwiftMQ implementation of JMS

In my product I am using SwiftMQ as the messaging service. I see that it uses a page.dg file and I read that it is the JMS transactional file. I see that it is growing very big in my enviroment upto 9 ...
6
votes
2answers
197 views

MQ to process, aggregate and publish data asynchronously

Some background, before getting to the real question: I am working on a back-end application that consists of several different modules. Each module is, currently, a command-line java application, ...
2
votes
2answers
452 views

JMS and AMQP - RabbitMQ

I am trying to understand what JMS and how it is connected to AMQP terminology. I know JMS is an API and AMQP is a protocol. Here are my assumptions (and questions as well) RabbitMQ uses AMQP ...
0
votes
2answers
125 views

ClassNotFoundException:KahaPersistenceAdapter in ACtiveMQ 5.8

I migrated my application from ActiveMQ 5.5.1 to ActiveMQ 5.8.0. My application has persistence configuration at activemq.xml file as following: <persistenceAdapter> ...
0
votes
1answer
93 views

I send a scheduled message to activemq broker but two message shown in web console

I wrote a simple ActiveMQ client program for produce a message as following: public static void main(String[] args) throws Throwable { final ActiveMQConnectionFactory conFactory = new ...
0
votes
1answer
36 views

My simple prgram does not complete and exit as long as activemq connection doesn't closed

I write a simple program by ActiveMQ as following: public static void main(String[] args) throws Throwable { final ActiveMQConnectionFactory conFactory = new ...
2
votes
1answer
185 views

PageFile is not loaded exception in activemq

I get PageFile is not loaded exception in production environment on produce a scheduled message. After search in web and don't find any solution I wrote a simple program for simulate production ...
0
votes
2answers
70 views

Workload queueing, ESB and message brokers [closed]

I am doing a bit of research on all these topics and I'm quite confused. My requirements: I have two external applications that produce some files and I need my web application to store them into ...
2
votes
4answers
92 views

Java enterprise architecture for delegating tasks between applications

In my environment I need to schedule long-running task. I have application A which just shows to the client the list of currently running tasks and allows to schedule new ones. There is also ...
0
votes
1answer
54 views

Better model for my case? RMI or Message System?

I need to build some processes to form a distributed system. I am in a dillema between RMI and JMS. Issues: I opted RMI since I already know it and it fits the distributed systems and it is fast. But ...
2
votes
2answers
278 views

Are there any MQ servers that can run embedded in a Java process?

I'm researching queuing solutions for one of my team's apps. Ideally we would like something that can be configured both as a lightweight, in-process broker (for low-throughput messaging between ...
1
vote
0answers
95 views

How to update values of a row in a table after polling for new incoming data in a loop

I had already implemented polling for this database in java and reads all incoming data which resides in the outgoingqueue. Now I have problems in updating the polled rows, which is like I just change ...
1
vote
1answer
305 views

RabbitMQ and Camel : route interrupted due to “Message dropped on recovery”

I'm having a frustrating issue with RabbitMQ and sprimg-amqp. I need to send a message to a queue from an external process (a JUnit class just to test if routing works well). This is my ...
0
votes
1answer
130 views

Local message-queue api/library for Java [closed]

I'm looking for a message-queue api/library for managing queues locally in java. What do you suggest to me? I don't want to use a Client/Server architecture, I'd rather do it locally to do not add a ...
-1
votes
1answer
165 views

JMS Queue/Topic questions

I have two questions about JMS: 1) What happens when the queue is down and the publisher is trying to send a message. What error I am going to get? 2) What happends when message is avaiable but the ...
0
votes
1answer
135 views

AMQP (Qpid) one to many queue

I have one producer, one queue and N consumers. Producer creates 'jobs' to be performed by consumers. I'd like to use pull model, in which consumer pulls job from queue, when it finishes the previous ...
1
vote
1answer
2k views

Cannot find the declaration of element 'beans'

I have the spring jars of spring-3.2.0.RC1.jar and trying to implement Apache ActiveMQ helloWorld program from tutorial given here. The xml configuration file is: <?xml version="1.0" ...
2
votes
2answers
214 views

Weird behavior when counting messages on JMS queue

I am using Active MQ and the Java JMS. I want to count the number of messages on the queue. One approach is counting the messeages with a browser: Queue queue = (Queue) ...
0
votes
2answers
200 views

Java: Implement own message queue (threadsafe)

The task is to implement my own messagequeue that is thread safe. My approach: public class MessageQueue { /** * Number of strings (messages) that can be stored in the queue. */ ...
1
vote
1answer
226 views

Count numner of messages in a queue

What is the best way to go over a queue and get all the messeages in it? How can count the number of messeages in a queue? Thnaks.
0
votes
2answers
67 views

Receiving number of messages from a queue

I am receiving messages from aActive MQ queue. Is there a way to receive a number of messages in one time? or is that have to be done with a loop? Further more, if i want to take say 30 messages run ...
3
votes
1answer
544 views

QueueBrowser does not return all messages

I list down queues and messages from each queue. The following is my code. But, QueueBrowser does not retrieve messages correctly. Let's say, I have a queue named TestQueue which has 1000 message. ...
0
votes
1answer
258 views

Message availability on JMS Topic once client acknowledges it?

I have a simple scenario, where publisher(my java application) publish the message on topic. 50 clients have subscribed on same JMS topic.As soon as message is published on topic, all the 50 ...
7
votes
1answer
373 views

Akka and Java libraries that use ThreadLocals

What has kept me from using Akka regularly (in Java) is a concern I have with libraries that use ThreadLocals. That is I think some Akka Dispatchers may cause ThreadLocal variables to be left ...
4
votes
1answer
634 views

Understanding zeromq java binding

I'm investigating zeromq as a message passing solution in a java project, but I find the instructions on java binding somewhat difficult to follow. http://www.zeromq.org/bindings:java I am ...
0
votes
2answers
181 views

Queuing / Worker Thread architecture for a single java process

I have the following problem to solve. I need to write a java program that: reads JSON object j1,j2,...,jn from a web service. does some number crunching on each object to come up with ...
0
votes
2answers
258 views

kaha db message store for persistent messages

I know db-xx.log is the journal file and db.redo is the reference file? db-xx.log stores messages which are not consumed, yet. Those messages will be deleted from db-xx.log after being consumed. ...
0
votes
1answer
88 views

ActiveMQ performance in different Operating Systems

I have tested activeMQ JMSProducer in some operating systems. The results are as follows: AIX - Persistent - around 50 messages per second Solaris - Persistent - around 60 messages per second ...
0
votes
1answer
1k views

RabbitMQ: messages remain “Unacknowledged”

My Java application sends messages to RabbitMQ exchange, then exchange redirects messages to binded queue. I use Springframework AMQP java plugin with RabbitMQ. The problem: message comes to queue, ...
2
votes
1answer
247 views

java message queue or read file manually

We have seperate Java instances program processing raw weblog like that: jvm instance 1 read fileA --> process jvm instance 2 read fileA ---> process jvm instance 3 read fileA ---> process ...
13
votes
4answers
811 views

Non-blocking queue of HTTP POST requests with persistence

Before we develop our custom solution, I'm looking for some kind of library, which provides: Non-blocking queue of HTTP requests with these attributes: Persisting requests to avoid it's loss in ...
0
votes
1answer
141 views

Uneven flow in ZMQ

I am using ZMQ in my Java application. I found that it behaves unevenly i.e if I send some 100 message with One consumer say it takes 1 sec then if we go on increasing the consumers the time taken ...
0
votes
2answers
127 views

Unique ids for jobs in a message queue?

I have an application which I'm writing which needs to perform long computations in the background, so I have essentially the following workflow: Client submits job to an edge "dispatcher" server. ...
0
votes
2answers
88 views

Even distribution using ZMQ

I am using Zmq in my Centos. My task is to write a java program using ZMQ which will have one producer and multiple consumers. If a Producer send 100 message and there are four consumers all the ...
0
votes
2answers
450 views

JMS poison message removal

I'm trying to debug a web app hostde on weblogic 10r3 server. The App is receiving input from foreign IBM JMS Queue (classname: com.ibm.mq.jms.MQQueue) via Java Message Driven Beans. I wrote a small ...
3
votes
2answers
433 views

Spring Integration

Our application has been designed using Spring Integration Framework. Complete message action flow starts with listening to Queue's for which JMS message driven adapters has been used after which ...
0
votes
1answer
147 views

how to use the queue-messaging family of methods in smslib?

I dont know how to implement the queue messaging in smslib, I receive a new sms and I store in a database table, I make some logic and then I produce a new sms, I already archieve this -synchronous ...

1 2 3
15 30 50 per page