import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
@GET
@Path("/Notifications/{ShopID}")
@Produces(SseFeature.SERVER_SENT_EVENTS)
@RolesAllowed({GlobalConstants.ROLE_SHOP_ADMIN})
public EventOutput listenToBroadcast(@PathParam("ShopID")int shopID) {
	final EventOutput eventOutput = new EventOutput();

	if(Globals.broadcasterMap.get(shopID)!=null)
	{
		SseBroadcaster broadcasterOne = Globals.broadcasterMap.get(shopID);
		broadcasterOne.add(eventOutput);
	}
	else
	{
		SseBroadcaster broadcasterTwo = new SseBroadcaster();
		broadcasterTwo.add(eventOutput);
		Globals.broadcasterMap.put(shopID,broadcasterTwo);
	}

	return eventOutput;
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
@GET
@Path("/Notifications/{ShopID}")
@Produces(SseFeature.SERVER_SENT_EVENTS)
public EventOutput listenToBroadcast(@PathParam("ShopID")int shopID) {
	final EventOutput eventOutput = new EventOutput();

	if(Globals.broadcasterMap.get(shopID)!=null)
	{
		SseBroadcaster broadcasterOne = Globals.broadcasterMap.get(shopID);
		broadcasterOne.add(eventOutput);
	}
	else
	{
		SseBroadcaster broadcasterTwo = new SseBroadcaster();
		broadcasterTwo.add(eventOutput);
		Globals.broadcasterMap.put(shopID,broadcasterTwo);
	}

	return eventOutput;
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
@GET
@Path("/Notifications/{EndUserID}")
@Produces(SseFeature.SERVER_SENT_EVENTS)
public EventOutput listenToBroadcast(@PathParam("EndUserID")int endUserID) {

	final EventOutput eventOutput = new EventOutput();

	if(Globals.broadcasterMapEndUser.get(endUserID)!=null)
	{
		SseBroadcaster broadcasterOne = Globals.broadcasterMapEndUser.get(endUserID);
		broadcasterOne.add(eventOutput);
	}
	else
	{
		SseBroadcaster broadcasterTwo = new SseBroadcaster();
		broadcasterTwo.add(eventOutput);
		Globals.broadcasterMapEndUser.put(endUserID,broadcasterTwo);
	}

	return eventOutput;
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
@GET
@Path("/{ShopID}")
@Produces(SseFeature.SERVER_SENT_EVENTS)
public EventOutput listenToBroadcast(@PathParam("ShopID")int shopID) {
    final EventOutput eventOutput = new EventOutput();

    if(Globals.broadcasterMap.get(shopID)!=null)
    {
        SseBroadcaster broadcasterOne = Globals.broadcasterMap.get(shopID);
        broadcasterOne.add(eventOutput);
    }
    else
    {
        SseBroadcaster broadcasterTwo = new SseBroadcaster();
        broadcasterTwo.add(eventOutput);
        Globals.broadcasterMap.put(shopID,broadcasterTwo);
    }
    return eventOutput;
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
/**
 * Ctor.
 * 
 * @param reactor
 *            the instance of reactor to use
 * @param store
 *            the instance of event store to use
 */
public EventResource(Reactor reactor, EventStore store) {
	this.broadcaster = new SseBroadcaster();
	this.store = store;
	this.reactors = reactor;
	this.lastEventId = new AtomicLong(-1);

	this.reactors.on(Selectors.object("out"), (reactor.event.Event<Long> lastEventId) -> {
		broadcast(lastEventId.getData().longValue());
	});
	this.reactors.on(Selectors.object("in"), (reactor.event.Event<Event> e) -> {
		store.use(e.getData());
		broadcast(this.lastEventId.longValue());
	});

	if (Boolean.getBoolean("visactor.demo")) {
		logger.warn("visactor demo mode is enabled.");
		startDemoEvents();
	}
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
/**
 * Constructor
 */
public InstrumentedSseBroadcaster() {
    super();
    final MetricRegistry registry = SharedMetricRegistries
            .getOrCreate("default");
    this.pingRate = registry
            .meter(name(SseBroadcaster.class, "broadcast", "ping-sends"));
    this.eventRate = registry
            .meter(name(SseBroadcaster.class, "broadcast", "event-sends"));
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
TimeGenerator( final SseBroadcaster broadcaster )
{
  _broadcaster = broadcaster;
}
 

import org.glassfish.jersey.media.sse.SseBroadcaster; //导入依赖的package包/类
TimeGenerator( final SseBroadcaster broadcaster,
               final Collection<AsyncResponse> waiters )
{
  _broadcaster = broadcaster;
  _waiters = waiters;
}