openmessaging-java
openmessaging-java copied to clipboard
openmessaging
OpenMessaging Runtime Interface for Java
Sometimes we use OMS.builder().build(properties) to create the MessagingAccessPoint, it can work well in most scenarios. But sometimes there are existed problem. If we load the `openmessaging-api` in `moduleA`, and we...
Your FOSSA integration was successful! Attached in this PR is a badge and license report to track scan status in your README. Below are docs for integrating FOSSA license checks...
https://github.com/openmessaging/openmessaging-java/issues/55 MessageReceipt support getMessageId and getOffset
In the openmessaging-java api， MessageReceipt is mainly used in the following APIs void ack(MessageReceipt receipt); Message receive(String queueName, QueueMetaData queueMetaData, MessageReceipt messageReceipt, long timeout); List batchReceive(String queueName, QueueMetaData queueMetaData, MessageReceipt...
As interface shows below： ``` /** * * Send batch messages to server. * * @param messages messages to be sent. */ void send(List messages); ``` This API can lead...
JD's messaging implementation supports sending multiple messages in a single transaction. Is there a need to improve the OpenMessaging API to be compatible with this feature?
Hi! Given the rising popularity of reactive APIs (also the Flow API in Java 9), such initiative as OpenMessaging should provide the first-class APIs for the reactive world. To define...
Besides Producer/Broker/Consumer topology, the Message/Stream communication use case could also apply to broker-less P2P communication. Basically, for the P2P communication, we could identify 4 communication styles: Type 1. Oneway message/stream...
