4
голосов
2ответов
4343 просмотров

How to get the number of JMS messages in a Topic

How do I get the number of JMS messages waiting to be consumed by a specific JMS message subscriber? I use the Topic model (publish/subscribe) and not the Queue model. I want my MDB (message driven bean) to be able to figure out this information about the topic it listens to. To be clear; I want...

7
голосов
2ответов
8033 просмотров

JMS equivalent in .Net

I am trying to make an common abstract interface over the messaging infrastructure in our company. The design goal is to 2 fold. 1 is to hide the complexity of programming from the developers (i know its not very complex but still simplify it further) and 2 is to make the developers independent o...

1
голосов
3ответов
661 просмотров

Blackboard messaging using queues

I have an application, where I need to add role-based messaging. The messages are generated ny the application itself, and every message have an starttime (where is show on the client message-window) and an expire-time. Depending on your role, you will see a subset of the messages. Some messages ...

73
голосов
7ответов
54861 просмотров

.net service bus recommendations?

We are in need of a distributed architecture messaging system/service bus with the capability of Publish/Subscribe. Does anyone have any reccomendations for a framework that we can use for .net applications?

5
голосов
1ответов
4761 просмотров

WSMQ Queue Limit

is there a limit on how many queues I can have open within a single connection and single session? I can currently open up 128 queues and send messages to them. If I try to open up 129 I get the following error... Thanks Error: com.ibm.msg.client.jms.DetailedResourceAllocationException: JMSW...

3
голосов
2ответов
726 просмотров

Message bus design - support implicit ordering of messages?

One important design decision that needs to be made when designing a corporate message bus is whether (and how) the message bus should support implicit ordering of messages. By implicit ordering, I mean the ability to deliver messages in exactly the same order as they were sent. There are severa...

2
голосов
3ответов
411 просмотров

Should I use messaging instead of a database

I am designing a system that will allow users to take data from one system and send to other systems. One of the destination systems has a sophisticated SOA (web services) and the other is a mainframe that accepts flat files for input. I have created a database that has a PublishEvent table and...

0
голосов
1ответов
82 просмотров

Using messaging to do writes as well as reads

I come from a web background where I only have to deal with HTTP so please excuse my ignorance. I have an app which where clients listen for changes in a message queue which uses stomp. Previously the client only needed to listen to the relevant channels for messages telling them about changes o...

0
голосов
1ответов
120 просмотров

Objectdeserialization over network

i am getting an excepetion when i try to read an object from an ObjectInputStream via network like this: Socket socket = new Socket("localhost", 4444); ObjectInputStream ois = new ObjectInputStream(socket.getInputStream()); while ((Object o = ois.readObject()) != null) { } Here is the exceptio...

2
голосов
3ответов
731 просмотров

how to design messages in a java client-server model

i have set up a basic client and a basic server using java sockets. it can successfully send strings between them. now i want to design some basic messages. could you give me any recommendations on how to lay them out? should i use java's serialzation to send classes? or should i just encode th...

0
голосов
1ответов
544 просмотров

JBoss Seam - Massive Messaging in Application

I'´m currently twiddling with an application that has a setup matching the following chat analogy: a chat is an object that is held in memory and contains a list of chat messages a chat is rendered in several browser windows and updates are pulled in with a4j:push The programmatic setup looks...

43
голосов
7ответов
22491 просмотров

Technique or utility to minimize Java "warm-up" time?

I am supporting a Java messaging application that requires low latency (<300 microseconds processing each message). However, our profiling shows that the Sun Java Virtual Machine runs slowly at first, and speeds up after the first 5,000 messages or so. The first 5,000 messages have latency of ...

1
голосов
1ответов
1843 просмотров

Asynchronous vs synchronous messagin

What is difference between Asynchronous vs synchronous messaging (java) and how does it impact way in which messaging sender / receiver is implemented. how does a J2EE architecture decides to choose either.

0
голосов
1ответов
124 просмотров

Exposing a service to external systems - How should I design the contract?

I know this question is been asked before here but still I'm not sure what to select. My service will be called from many 3 party system in the enterprise. I'm almost sure the information the service will collect (MyBigClassWithAllInfo) will change during the products lifetime. Is it still a goo...

0
голосов
2ответов
775 просмотров

Design patterns for messaging / event driven infrastructure

I'm building my first system that relies heavily on a message queue for reasons other than scaling. To cut a long story short there will be many clients connected to a central server via the internet, each client has the ability to edit data on the server, when such an event occurs the other clie...

0
голосов
4ответов
250 просмотров

Observer in a distributed environment

Machine A needs to send a message to machine B. Machine A has a static IP but machine B does not. One option I could think of to solve this problem is that machine B opens a TCP connection to machine A and then machine A sends the data/message to machine B. However, this solution has the followi...

1
голосов
2ответов
1194 просмотров

Can you send messages using MSMQ to a machine not in the same domain?

I haven't read enough about or used MSMQ till now. For many years now, I've only known that they exist. So, forgive me if my question indicates lack of rudimentary knowledge on the subject. If I have to send a message from machine A to machine B, but they are not on the same network, is it possi...

2
голосов
2ответов
1056 просмотров

Best database design for a discussion system with varying category types?

I would like to design a message inbox table schema for messages which may belong to individual users or user groups. Let's say we have these tables already: users table with uid (PK) groups table with gid (PK) groups_association table with gid (FK) and uid (FK) Then, what would be the best...

5
голосов
1ответов
2521 просмотров

Multiple consumers for a single queue in MassTransit

Is it possible to have several consumers listening on a single MSMQ instance and use the Selective Consumer interface for having each one deal with a distinct subset of the messages? I can't seem to get this scenario to work correctly using pub/sub - a single consumer on the queue works fine, bu...

0
голосов
1ответов
283 просмотров

Does one use WF and WCF together to build a messaging system?

I am looking to build an messaging infrastructure to facilitate communications between different systems in our organization. There are many way to go about this. I have looked into nServiceBus and MassTransit. How does WF/WCF fit into this - if at all? If it does, are there any good articles,...

3
голосов
4ответов
784 просмотров

Interthread communication time

I am chaining together 15 async operations through ports and receivers. This has left me very concerned with the interthread messaging time, specifically the time it takes between a task posting data to a port, and a new task begins processing that same data on a different thread. Assuming best c...

3
голосов
3ответов
1653 просмотров

jGrowl: How can I limit my interface to one message at a time?

Given: I load a queue of messages at page load. With jGrowl, how can I display each message, one message at a time, in a drip-like fashion?

2
голосов
2ответов
321 просмотров

EAI/middleware: Huge messages inline or by reference

Are there good practices for processing messages or requests/responses dealing with huge amounts of data (MBytes? GBytes?) via an middleware or an EAI system, assunming that the middleware transports but does not process the huge data blobs? Transport the data with the message in order to keep ...

1
голосов
4ответов
3998 просмотров

Why i should use ActiveMQ for send emails?

many weeks ago recommended me for send emails, ActiveMQ. So i search information about this, but i don't understand totally how this works. Could someone explain me why i should use ActiveMQ for send emails ?

0
голосов
3ответов
4346 просмотров

How to pause JMS topic subscriber from receiving messages

My setup: JBoss Messaging 1.4 running on JBoss 4.2.3 I have a couple of MDB's that subscribes on one topic, and the MDB's onMessage() tries to deliver the received message to one web service each. My problem is that I can't figure out how to pause the subscriptions in the case when the web serv...

2
голосов
2ответов
114 просмотров

How should I go about guaranteeing that a "message" is sent and stored once and only once?

I'm working on designing an EDI system for two companies: Company A and Company B. Company A already exists as a small manufacturing business, and Company B is a new company formed around a specific product with the involvement of the owner of Company A. Company A will have exclusive rights to pr...

4
голосов
3ответов
542 просмотров

How to see windows messages of a dialog shown with a second thread?

I've registered a message filter using Application.AddMessageFilter(m_messageFilter); using this I can log all of the mouse clicks a user makes in the application's user interface. However, one dialog is run on a separate thread, with code something like: void Run() { using( MyDialog dia...

4
голосов
1ответов
1040 просмотров

Idempotency Barrier for messaging

A recent presentation I saw regarding RabbitMQ mentioned the use of something called an "idempotency barrier" for message de-duplication. Is this just a fancy name for a message conflator or is it something more specific. If so, what exactly is it? A google search yielded results which are mostly...

1
голосов
2ответов
319 просмотров

Messaging Middleware - how to avoid reentrance with wildcard subscription?

Messaging middleware solutions (JMS, Tibco, etc.) allow publish/subscribe with "topic" filtering using wildcards to subscribe to all messages of a certain "topic", e.g. SUBSCRIBE("ACCOUNT.*") topic allows you to subscribe to both "ACCOUNT.WITHDRAW" message and "ACCOUNT.CHECKBALANCE" message. The...

9
голосов
1ответов
8086 просмотров

In a FIFO Qeueing system, what's the best way the to implement priority messaging

For message-oriented middleware that does not consistently support priority messages (such as AMQP) what is the best way to implement priority consumption when queues have only FIFO semantics? The general use case would be a system in which consumers receive messages of a higher priority before ...