Questions tagged [wso2-message-broker]

WSO2 Message Brokers enable applications to exchange communications asynchronously or publish messages for timely access by many subscribers. For example, news bureaus can publish different categories of news – business, sports, science and technology, weather – and consumers can subscribe to the latest news that interests them.

Message Brokers enable applications to exchange communications asynchronously or publish messages for timely access by many subscribers. For example, news bureaus can publish different categories of news – business, sports, science and technology, weather – and consumers can subscribe to the latest news that interests them.

Features

Standards Compliant, Portable, Interoperable Message Broker

  • Support for JMS v1.0 and v1.1 API
  • Advanced Message Queuing Protocol (AMQP) v0.91, the only industry standard protocol for interoperable reliable messaging
  • Interoperability with many languages / platforms via AMQP clients for Java, .Net, C, C++, PHP, Ruby, Erlang and more
  • Support for in memory message store to improve performance.

Distributed, Highly Scalable, Fault-Tolerant and Persistent Message Broker with Apache Cassandra and Apache ZooKeeper

  • Apache Cassandra NoSQL storage to store messages persistently and share messages across multiple broker nodes
  • Apache ZooKeeper for message coordination and failure recovery
  • Flexible deployment model supporting single node execution to massively distributed execution
  • Support for Cassandra replication factor, read/write consistency levels configuration.

Elastically Scalable Broker Architecture

  • Broker capacity can be adjusted by adding/removing broker nodes
  • Brokers can be added/removed at run-time without system restart
  • Client connections get automatically redistributed as loads change
  • Message storage capacity scales linearly as new brokers are added using underlying Cassandra ring
  • Intelligently allocate the load among brokers using Zookeeper coordination

Support for Distributed Queues

  • Publishers and subscribers can connect to any broker
  • Support for In-Order Reliable Message Delivery
  • Support for strict and best effort (faster) delivery guarantees

Support for Publish/Subscribe Model (Topics)

  • Publishers and subscribers can connect to any
  • Can publish and subscribe using JMS or WS-Eventing
  • Support interoperability between JMS and WS-Eventing clients

Management Console

  • Centralized governance of topics via integration to WSO2 Governance Registry
  • Console to manage the Cluster and to view statistics about the cluster
  • Support to browse Publish/Subscribe topics through management console
  • Support to create, delete queues and browse queues using management console
  • Support to display the messages inside a queue, send a test message to a queue, and purge the messages in the queue using management console.

Manage & Monitor

  • Comprehensive management & monitoring Web console with enterprise-level security
  • Built-in collection and monitoring of standard access and performance statistics
  • JMX MBeans for key metrics monitoring and management
  • Integrates with WSO2 Business Activity Monitor for operational audit and KPI monitoring and management
  • Flexible logging support with integration to enterprise logging systems
  • Centralized configuration management across different environments with lifecycles and versioning via integration to WSO2 Governance Registry
  • User based authorization support for queues
  • Role based authorization support for topics
84 questions
6
votes
5 answers

How can I set the message processor interval parameter using a non fixed value? (using a value stored in a property\registry\etc)

I am very new to WSO2 ESB and I have the following problem with a message processor. I have this message processor definiation that every second extract an element (an XML document previously stored) from a queue and process it calling a sequence…
AndreaNobili
  • 40,955
  • 107
  • 324
  • 596
4
votes
1 answer

java.lang.OutOfMemoryError: GC overhead limit exceeded on WSO2 MB

I've been recently working on with the WSO2 Message Broker (Ver : 3.1.0 ) in order to publish and consume messages using JMeter as the jms client. So I've got my publisher Java program where I'm publishing the messages from and I'm trying to publish…
Kulasangar
  • 9,046
  • 5
  • 51
  • 82
4
votes
2 answers

WSO2 Message Broker Error while adding Queue - Invalid Object Name

I have just set up a WSO2 Message Broker 3.0.0 connecting to a SQL Server DB. The DB for the Carbon MB component has been created successfully as well. The DB for the Message Broker Data store is created and contains the table…
AzA
  • 51
  • 5
3
votes
1 answer

Errors when handling multiple topics, publishers and subscribers + WSO2MB

I've got the Message Broker 3.1.0, and I'm trying to publish messages through a java program and subscribe through the JMeter script which I'm running it in headless mode in Windows. So in my case I've got three topics added in the MB,three…
Kulasangar
  • 9,046
  • 5
  • 51
  • 82
2
votes
1 answer

How many and what databases I have to create for a WSO2 EI two node cluster like this (each node contains ESB and MB profiles)

I am installing a WSO2 EI two nodes cluster and I have some doubts about the number of databases that have to be created. I will try to explain my situation as best that I can: I am using WSO2 EI 6.5.0. I have two nodes cluster. Each node contains…
AndreaNobili
  • 40,955
  • 107
  • 324
  • 596
2
votes
1 answer

Clustering WSO2 EI ESB and WSO2 EI MB profiles, WKA vs Multicast? Are my assumptions correct?

I have to create and configure a two node WSO2 EI cluster. In particular I have to cluster an ESB profile and MB profile. I have some architectural doubts about this: CLUSTERING ESB PROFILE DOUBTS: I based my assumptions on this documentation:…
2
votes
0 answers

WSO2 Message Broker Rest ApI Example

I have used WSO2 Message broker for JSON data transfer one service to other many services (using Topic). When I connect to other services. So I need to check that service availability. connection loss try again several time till connect…
Thusitha Indunil
  • 832
  • 1
  • 8
  • 22
2
votes
1 answer

wso2esb + websocket - ConcurrentModificationException error

I am using wso2esb + wso2mb + websockets to transform JMS messages from wso2mb to websockets. During my performance tests (I have tried to send 7k messages from wso2mb to websocket) I got following errror…
bontade
  • 3,194
  • 6
  • 48
  • 75
2
votes
1 answer

Exceptional Cases In wso2 Message Broker

I am using wso2 message broker as a message brokering system in my project. Before using wso2 message broker, I want to explore exceptional cases related to wso2 message broker queue/topic - How many messages queue/topic can store if consumer is…
Abhishek
  • 315
  • 5
  • 18
2
votes
3 answers

WSO2 MB 3.0.0 Startup Error : Wait until Qpid server starts on port 5672

I just downloaded the WSO2 MB 3.0.0. And when I trying to start server I'm getting following error. [2016-04-28 14:43:21,986] ERROR {org.wso2.carbon.andes.internal.QpidServiceComponent} - Wait until Qpid server starts on port…
jay
  • 477
  • 5
  • 13
2
votes
1 answer

How to subscribe a topic in WSO2 MB 3.1.0

I've been working with the WSO2 Message Broker for a while and I clearly understood the way of publishing and consuming a message to and from a queue as well topics. According to this, it has not been mentioned anywhere how could I subscribe to a…
2
votes
0 answers

Setting up WSO2ESB to send messages to WSO2MB

I am trying to get our proxy in wso2ESB to send messages to the wso2 Message Broker. I'm reading the article for integrating the ESB to MB which says to "Open /repository/conf/ JNDI.proerties file and point to the running Message Broker." Where can…
John
  • 73
  • 7
1
vote
1 answer

SSL connection refused with NEED_WRAP

Current situation. There are 2 nodes on the same internal network (let's call them Bus and Broker). The internal CA has signed a request made 2 weeks ago. This signed certificate has been inserted correctly into the Broker's "keystore" as well as…
JustLudo
  • 1,690
  • 12
  • 29
1
vote
0 answers

How to use private NTP service (instedad pool.ntp.org) in the syncronization of WSO2 MB cluster nodes?

I am installing a WSO2 MB in a two node cluster. I am following the official documentation: https://docs.wso2.com/display/EI650/Clustering+the+Message+Broker+Profile#ClusteringtheMessageBrokerProfile-Mountingtheregistry I have the following doubt…
AndreaNobili
  • 40,955
  • 107
  • 324
  • 596
1
vote
1 answer

Can't run wso2 esb after doing wso2 mb tutorial

I'm trying to catch up with the new realease of the wso2ei 7 and 'm following the new tutorial but I keep getting an error when I start the esb again with the following error Store [PaymentRequestMessageStore]. Could not initialize JMS Message…
1
2 3 4 5 6