<commit_before>package org.yamcs.api;

import static org.junit.Assert.*;


import org.hornetq.core.server.embedded.EmbeddedHornetQ;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.yamcs.YamcsServer;

import org.yamcs.api.HornetQEventProducer;
import org.yamcs.api.Protocol;
import org.yamcs.api.YamcsClient;
import org.yamcs.api.YamcsSession;
import org.yamcs.protobuf.Yamcs.Event;
import org.yamcs.yarch.YarchTestCase;

public class TestEventProducer extends YarchTestCase {
    static EmbeddedHornetQ hornetServer;
    
    @BeforeClass
    public static void setUpBeforeClass1() throws Exception {
        hornetServer=YamcsServer.setupHornet();
    }

    @AfterClass
    public static void tearDownAfterClass() throws Exception {
        hornetServer.stop();
    }
    
    @Test
    public void testEventProducer() throws Exception {
        String url = "yamcs:///"+ydb.getName();
        YamcsSession ys=YamcsSession.newBuilder().setConnectionParams(url).build();
        HornetQEventProducer ep= new HornetQEventProducer(YamcsConnectData.parse(url));<commit_msg>more cleanup<commit_after>package org.yamcs.api;

import static org.junit.Assert.*;


import org.hornetq.core.server.embedded.EmbeddedHornetQ;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.yamcs.YamcsServer;

import org.yamcs.api.HornetQEventProducer;
import org.yamcs.api.Protocol;
import org.yamcs.api.YamcsClient;
import org.yamcs.api.YamcsSession;
import org.yamcs.protobuf.Yamcs.Event;
import org.yamcs.yarch.YarchTestCase;

public class TestEventProducer extends YarchTestCase {
    static EmbeddedHornetQ hornetServer;
    
    @BeforeClass
    public static void setUpBeforeClass1() throws Exception {
        hornetServer=YamcsServer.setupHornet();
    }

    @AfterClass
    public static void tearDownAfterClass() throws Exception {
	YamcsServer.stopHornet();
    }
    
    @Test
    public void testEventProducer() throws Exception {
        String url = "yamcs:///"+ydb.getName();
        YamcsSession ys=YamcsSession.newBuilder().setConnectionParams(url).build();
        HornetQEventProducer ep= new HornetQEventProducer(YamcsConnectData.parse(url));
{'fraction_non_alphanumeric': 0.09780170480035891, 'fraction_numerical': 0.0008972633467922835, 'mean_word_length': 4.347721822541966, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5010912', 'n_tokens_mistral': 740, 'n_tokens_neox': 735, 'n_words': 132}