AbstractEventBus (Grails Async Framework

org.grails.events.bus.AbstractEventBus

All Implemented Interfaces and Traits:

EventBus
```
@groovy.transform.CompileStatic
abstract class AbstractEventBus
```
Abstract event bus impl
Authors:
Graeme Rocher
Since:
6.1

Nested Class Summary

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

Field Summary

Fields
Modifiers	Name	Description
`protected java.util.Map<java.lang.CharSequence, java.util.Collection<Subscription>>`	`subscriptions`

Methods Summary

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

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

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

Summary:
Nested
Field
Method

| Detail:
Field
Method

[Groovy] Class AbstractEventBus

Nested Class Summary

Field Summary

Methods Summary

Inherited Methods Summary

Field Detail

protected final java.util.Map<java.lang.CharSequence, java.util.Collection<Subscription>> subscriptions

Method Detail

protected ClosureSubscription buildClosureSubscription(java.lang.CharSequence eventId, groovy.lang.Closure subscriber)

protected java.util.concurrent.Callable buildNotificationCallable(Event event, java.util.Collection<Subscription> eventSubscriptions, groovy.lang.Closure reply = null)

protected final AbstractEventBus.NotificationTrigger buildNotificationTrigger(Event event, java.util.Collection<Subscription> eventSubscriptions, groovy.lang.Closure reply = null)

protected EventSubscriberSubscription buildSubscriberSubscription(java.lang.CharSequence eventId, Subscriber subscriber)

@java.lang.Override boolean isActive()

@java.lang.Override final EventEmitter notify(java.lang.CharSequence eventId, java.lang.Object... data)

EventEmitter notify(Event event)

@java.lang.Override EventEmitter notify(Event event, TransactionPhase transactionPhase)

@java.lang.Override Subscription on(java.lang.CharSequence event, groovy.lang.Closure subscriber)

@java.lang.Override final EventEmitter publish(java.lang.CharSequence eventId, java.lang.Object... data)

@java.lang.Override final EventEmitter publish(Event event)

@java.lang.Override EventEmitter publish(Event event, TransactionPhase transactionPhase)

@java.lang.Override final EventEmitter sendAndReceive(java.lang.CharSequence eventId, java.lang.Object data, groovy.lang.Closure reply)

@java.lang.Override EventEmitter sendAndReceive(Event event, groovy.lang.Closure reply)

@java.lang.Override final Subscription subscribe(java.lang.CharSequence event, groovy.lang.Closure subscriber)

@java.lang.Override Subscription subscribe(java.lang.CharSequence event, Subscriber subscriber)

@java.lang.Override Subjects unsubscribeAll(java.lang.CharSequence event)