AbstractEventBus (Grace Events Framework

org.grails.events.bus.AbstractEventBus

All Implemented Interfaces and Traits:

EventBus
```
@CompileStatic
abstract class AbstractEventBus
extends Object
implements EventBus
```
Abstract event bus impl
Authors:
Graeme Rocher
Michael Yan
Since:
6.1

Nested Class Summary

Nested classes
Modifiers	Name	Description
`class`	`AbstractEventBus.1`
`protected static class`	`AbstractEventBus.EventTriggerTransactionSynchronization`
`protected static class`	`AbstractEventBus.NotificationTrigger`

Field Summary

Fields
Modifiers	Name	Description
`protected Map<CharSequence, Collection<Subscription>>`	`subscriptions`

Constructor Summary

Constructors
Constructor and description
`AbstractEventBus()`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`protected ClosureSubscription`	`buildClosureSubscription(CharSequence eventId, Closure subscriber)`
	`protected abstract Callable`	`buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)` Build a new trigger to set off notifications
	`protected final AbstractEventBus.NotificationTrigger`	`buildNotificationTrigger(Event event, Collection<Subscription> eventSubscriptions, Closure reply)` Build a new trigger to set off notifications
	`protected EventSubscriberSubscription`	`buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)`
	`boolean`	`isActive()`
	`final EventEmitter`	`notify(CharSequence eventId, Object[] data)`
	`EventEmitter`	`notify(Event event)`
	`EventEmitter`	`notify(Event event, TransactionPhase transactionPhase)`
	`Subscription`	`on(CharSequence event, Closure subscriber)`
	`final EventEmitter`	`publish(CharSequence eventId, Object[] data)`
	`final EventEmitter`	`publish(Event event)`
	`EventEmitter`	`publish(Event event, TransactionPhase transactionPhase)`
	`final EventEmitter`	`sendAndReceive(CharSequence eventId, Object data, Closure reply)`
	`EventEmitter`	`sendAndReceive(Event event, Closure reply)`
	`final Subscription`	`subscribe(CharSequence event, Closure subscriber)`
	`Subscription`	`subscribe(CharSequence event, Subscriber subscriber)`
	`Subjects`	`unsubscribeAll(CharSequence event)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class Object`	`equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- Field Detail
  - protected final Map<CharSequence, Collection<Subscription>> subscriptions
- Constructor Detail
  - AbstractEventBus()
- Method Detail
  - protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)
  - protected abstract Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)
    
    Build a new trigger to set off notifications @return
    Parameters:
    event - The event
    eventSubscriptions - The subscriptions
    reply
  - protected final AbstractEventBus.NotificationTrigger buildNotificationTrigger(Event event, Collection<Subscription> eventSubscriptions, Closure reply)
    
    Build a new trigger to set off notifications @return
    Parameters:
    event - The event
    eventSubscriptions - The subscriptions
    reply
  - protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)
  - @Override
    boolean isActive()
  - @Override
    final EventEmitter notify(CharSequence eventId, Object[] data)
  - EventEmitter notify(Event event)
  - @Override
    EventEmitter notify(Event event, TransactionPhase transactionPhase)
  - @Override
    Subscription on(CharSequence event, Closure subscriber)
  - @Override
    final EventEmitter publish(CharSequence eventId, Object[] data)
  - @Override
    final EventEmitter publish(Event event)
  - @Override
    EventEmitter publish(Event event, TransactionPhase transactionPhase)
  - @Override
    final EventEmitter sendAndReceive(CharSequence eventId, Object data, Closure reply)
  - @Override
    EventEmitter sendAndReceive(Event event, Closure reply)
  - @Override
    final Subscription subscribe(CharSequence event, Closure subscriber)
  - @Override
    Subscription subscribe(CharSequence event, Subscriber subscriber)
  - @Override
    Subjects unsubscribeAll(CharSequence event)

| Detail:
Field
Constructor
Method

Groovy Documentation

[Groovy] Class AbstractEventBus

Nested Class Summary

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected final Map<CharSequence, Collection<Subscription>> subscriptions

Constructor Detail

AbstractEventBus()

Method Detail

protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)

protected abstract Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

protected final AbstractEventBus.NotificationTrigger buildNotificationTrigger(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)

@Override
boolean isActive()

@Override
final EventEmitter notify(CharSequence eventId, Object[] data)

EventEmitter notify(Event event)

@Override
EventEmitter notify(Event event, TransactionPhase transactionPhase)

@Override
Subscription on(CharSequence event, Closure subscriber)

@Override
final EventEmitter publish(CharSequence eventId, Object[] data)

@Override
final EventEmitter publish(Event event)

@Override
EventEmitter publish(Event event, TransactionPhase transactionPhase)

@Override
final EventEmitter sendAndReceive(CharSequence eventId, Object data, Closure reply)

@Override
EventEmitter sendAndReceive(Event event, Closure reply)

@Override
final Subscription subscribe(CharSequence event, Closure subscriber)

@Override
Subscription subscribe(CharSequence event, Subscriber subscriber)

@Override
Subjects unsubscribeAll(CharSequence event)

[Groovy] Class AbstractEventBus

Nested Class Summary

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected final Map<CharSequence, Collection<Subscription>> subscriptions

Constructor Detail

AbstractEventBus()

Method Detail

protected ClosureSubscription buildClosureSubscription(CharSequence eventId, Closure subscriber)

protected abstract Callable buildNotificationCallable(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

protected final AbstractEventBus.NotificationTrigger buildNotificationTrigger(Event event, Collection<Subscription> eventSubscriptions, Closure reply)

protected EventSubscriberSubscription buildSubscriberSubscription(CharSequence eventId, Subscriber subscriber)

@Overrideboolean isActive()

@Overridefinal EventEmitter notify(CharSequence eventId, Object[] data)

EventEmitter notify(Event event)

@OverrideEventEmitter notify(Event event, TransactionPhase transactionPhase)

@OverrideSubscription on(CharSequence event, Closure subscriber)

@Overridefinal EventEmitter publish(CharSequence eventId, Object[] data)

@Overridefinal EventEmitter publish(Event event)

@OverrideEventEmitter publish(Event event, TransactionPhase transactionPhase)

@Overridefinal EventEmitter sendAndReceive(CharSequence eventId, Object data, Closure reply)

@OverrideEventEmitter sendAndReceive(Event event, Closure reply)

@Overridefinal Subscription subscribe(CharSequence event, Closure subscriber)

@OverrideSubscription subscribe(CharSequence event, Subscriber subscriber)

@OverrideSubjects unsubscribeAll(CharSequence event)

@Override
boolean isActive()

@Override
final EventEmitter notify(CharSequence eventId, Object[] data)

@Override
EventEmitter notify(Event event, TransactionPhase transactionPhase)

@Override
Subscription on(CharSequence event, Closure subscriber)

@Override
final EventEmitter publish(CharSequence eventId, Object[] data)

@Override
final EventEmitter publish(Event event)

@Override
EventEmitter publish(Event event, TransactionPhase transactionPhase)

@Override
final EventEmitter sendAndReceive(CharSequence eventId, Object data, Closure reply)

@Override
EventEmitter sendAndReceive(Event event, Closure reply)

@Override
final Subscription subscribe(CharSequence event, Closure subscriber)

@Override
Subscription subscribe(CharSequence event, Subscriber subscriber)

@Override
Subjects unsubscribeAll(CharSequence event)