rabbitmqinject.groovy

rabbitmqinject.groovy

import com.rabbitmq.client.*
import java.util.Random  

@Grab(group='com.rabbitmq', module='amqp-client', version='1.7.2')
params = new ConnectionParameters(
    username: 'guest',
    password: 'guest',
    virtualHost: '/',
    requestedHeartbeat: 0
)
factory = new ConnectionFactory(params)
conn = factory.newConnection('127.0.0.1', 5672)
channel = conn.createChannel()
exchangeName = 'stockExchange'
key = 'key.a'

Random rand = new Random()  
int max = 10  
while(true){

    int next = rand.nextInt(max+1)  
    String msg = "${next}"
    channel.basicPublish(exchangeName, key , MessageProperties.TEXT_PLAIN , msg.bytes)
    Thread.sleep(300)
}

channel.close()
conn.close()