const keySource = new MockKeySource();
const dataSource = new MockDataSource<string>();

const bmq = new BlockchainMQ({
  keySource,
  dataSource,
  ownKey: await keySource.getMyKey('my_org_id'),
  pollingInterval: 1000,
});

const topic = 56; // Some topic number

// Listening for new messages
const emitter = await bmq.poll<string>(topic);
let lastCursor;

emitter.on('message', (message) => {
    console.log(message);
});

emitter.on('newCursor', (cursor) => {
  lastCursor = cursor; // In production, you must save cursor and resume from this another time you need polling
});

await bmq.send<string>(
    topic, // Topic number
    'Hello!',
    'some_receiver_org_id',
);

// Broadcast message
await bmq.send<string>(
    topic,
    'Hello!'
);


emitter.stop(); // Stop polling

bmq.stopAll(); // You can use this method instead of calling "stop" of each emitter

import { AggregionBlockchain } from '@aggregion/dmp-contracts';

const client = new AggregionBlockchain(nodeUrl, [
  pair1.privateKey,
  pair2.privateKey,
]);

const blockchainMQ = new BlockchainMQ({
  keySource: new EosKeySource({
    contractName: 'dmpusers',
    client: client,
  }),
  dataSource: new EosDataSource({
    contractName: 'dmpusers',
    client: client,
    clientAccount: 'your_orgId', // Id of your organization in orgsv2 table
  }),
  ownKey: {
    orgId: 'your_orgId',// Id of your organization in orgsv2 table
    data: 'your organization private key', // Not blockchain key! It is private part of public key saved in orgsv2 table
    format: KeyFormat.PKCS1_PEM,
    algo: KeyAlgo.RSA_4096,
  },
  pollingInterval: 500,
});