Guava入门~EventBus~Event Publishing示例

Event Publishing示例

public class SimpleTradeExecutor {
	private EventBus eventBus;
	
	public SimpleTradeExecutor(EventBus eventBus) {
		this.eventBus = eventBus;
	}
	
	public void executeTrade(TradeAccount tradeAccount, double amount, TradeType tradeType){
		TradeAccountEvent tradeAccountEvent = processTrade(tradeAccount, amount, tradeType);
		eventBus.post(tradeAccountEvent);
	}
	
	private TradeAccountEvent processTrade(TradeAccount tradeAccount, double amount, TradeType tradeType){
		Date executionTime = new Date();
		String message = 
			String.format("Processed trade for %s of amount %n type %s @%s",
					tradeAccount,amount,tradeType,executionTime);
		TradeAccountEvent tradeAccountEvent = new TradeAccountEvent(tr
		adeAccount,amount,executionTime,tradeType);
		System.out.println(message);
		return tradeAccountEvent;
	}
}