module Bug;

global my_event: event();

export {
    const broker_port: port = 9999/tcp &redef;
    redef Broker::endpoint_name = "connector";
}

event bro_init()
{
    suspend_processing();
    Broker::enable();
    Broker::connect("127.0.0.1", broker_port, 1sec);
    ##Broker::auto_event("bro/event/new_packet", new_packet);
}

event Broker::outgoing_connection_established(peer_address: string, peer_port: port, peer_name: string)
{
    print "Broker::outgoing_connection_established", peer_address, peer_port, peer_name;
    continue_processing();
}

event new_packet(c: connection, p: pkt_hdr)
{
    local ts: time = network_time();
    print ts;
}