AMQP Service

Stay ahead of the market with real-time notifications from SmartInsiderTrades.

Our AMQP service lets you receive automatic updates based on insider trading events. Subscribe to the topics that matter to you and never miss a critical market movement.

The AMQP Service is available exclusively with the 'advanced' subscription.

What Can You Subscribe To?

• Anomalies Detection - Get notified when unusual insider trading patterns occur.
  At the moment, the SIT platform identifies only one type of anomaly: UBSTA.
• All Insider Transactions - Receive a full real-time feed of all insider trades.
• SITI index - Our own insider sentiment index.
• High-Value Transactions - Filter transactions over $1 million for high-impact signals.
• Stock Sense - Receive automatic updates from our premier ML model, designed to predict stock prices based on insider activities.

amqps://username:password@smartinsidertrades.com:5671

You can connect to our AMQP service using your primary email (username) and API key (password), which was allocated to you and is visible under 'API Key' in your profile.

Node.js Example (Using amqplib):

        const amqp = require("amqplib");

        async function connect() {
            const amqpUrl = "amqps://username:password@smartinsidertrades.com:5671";
            const queueName = "transactions"; 

            try {
                const connection = await amqp.connect(amqpUrl);
                const channel = await connection.createChannel();

                await channel.assertQueue(queueName, {
                    durable: true,
                    arguments: { "x-queue-type": "classic" },
                });

                console.log(`Listening for messages on "${queueName}"...`);

                // Consume messages from the queue
                channel.consume(queueName, (msg) => {
                    if (msg !== null) {
                        try {
                            const messageContent = JSON.parse(msg.content.toString()); 
                            console.log("Received Message:", messageContent);
                        } catch (err) {
                            console.error("Error parsing JSON message:", err);
                        }

                        channel.ack(msg);
                    }
                });
            } catch (error) {
                console.error("Error connecting to RabbitMQ:", error);
            }
        }

        connect();
        

Available Streams

NB: The standard message TTL for all queues is 7 days.

FAQ