Modifier and Type | Method and Description |
---|---|
protected ActivityUnit |
AbstractActivityCollector.createActivityUnit()
This method creates a new activity unit and
initializes its origin based on the template
supplied by the OriginInitializer, if
available.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
BatchedActivityUnitLogger.appendActivity(ActivityUnit act)
This method appends the supplied activity event to the log.
|
void |
BatchedActivityUnitLogger.log(ActivityUnit act)
This method records the supplied activity event.
|
void |
ActivityUnitLogger.log(ActivityUnit act)
This method records the supplied activity event.
|
protected void |
AbstractActivityCollector.startScope(ActivityUnit au)
This method starts the scope associated with the supplied activity unit.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ActivityServerLogger.appendActivity(ActivityUnit act)
This method appends the supplied activity event to the log.
|
Constructor and Description |
---|
ActivityUnit(ActivityUnit act)
The copy constructor.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
ActivityStore.getActivityUnit(String id)
This method queries the persistent store for an activity unit
with the supplied id.
|
ActivityUnit |
ActivityServer.getActivityUnit(String id)
This method queries the server for an activity unit
with the supplied id.
|
Modifier and Type | Method and Description |
---|---|
void |
ActivityNotifier.notify(List<ActivityUnit> activities)
This method notifies when a list of activity events have
been reported.
|
void |
ActivityStore.store(List<ActivityUnit> activities)
This method stores the list of activity events.
|
void |
ActivityServer.store(List<ActivityUnit> activities)
This method stores the supplied activity events.
|
Modifier and Type | Method and Description |
---|---|
void |
EPNActivityNotifier.notify(List<ActivityUnit> activities)
This method notifies when a list of activity events have
been reported.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
JMSActivityServer.getActivityUnit(String id)
This method queries the server for an activity unit
with the supplied id.
|
Modifier and Type | Method and Description |
---|---|
void |
JMSActivityServer.store(List<ActivityUnit> activities)
This method stores the supplied activity events.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
RESTActivityServer.getActivityUnit(String id)
This method queries the server for an activity unit
with the supplied id.
|
Modifier and Type | Method and Description |
---|---|
void |
RESTActivityServer.store(List<ActivityUnit> activities)
This method stores the supplied activity events.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
ElasticsearchActivityStore.getActivityUnit(String id) |
Modifier and Type | Method and Description |
---|---|
protected void |
ElasticsearchActivityStore.persist(BulkRequestBuilder localBulkRequestBuilder,
String id,
ActivityUnit activityUnit)
This method persists the activity unit in the Elasticsearch repository.
|
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchActivityStore.store(List<ActivityUnit> activities) |
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
JPAActivityStore.getActivityUnit(String id)
This method queries the persistent store for an activity unit
with the supplied id.
|
Modifier and Type | Method and Description |
---|---|
void |
JPAActivityStore.remove(ActivityUnit au)
This method removes the supplied activity unit.
|
Modifier and Type | Method and Description |
---|---|
void |
JPAActivityStore.store(List<ActivityUnit> activities)
This method stores the list of activity events.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
MemActivityStore.getActivityUnit(String id)
This method queries the persistent store for an activity unit
with the supplied id.
|
Modifier and Type | Method and Description |
---|---|
void |
MemActivityStore.store(List<ActivityUnit> activities)
This method stores the list of activity events.
|
Modifier and Type | Method and Description |
---|---|
static ActivityUnit |
ActivityUtil.deserializeActivityUnit(byte[] act)
This method deserializes an Activity event from a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
static List<ActivityUnit> |
ActivityUtil.deserializeActivityUnitList(byte[] act)
This method deserializes an Activity Unit list from a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
static byte[] |
ActivityUtil.serializeActivityUnit(ActivityUnit act)
This method serializes an Activity event into a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
static byte[] |
ActivityUtil.serializeActivityUnitList(List<ActivityUnit> activities)
This method serializes an ActivityUnit list into a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
ServiceDefinitionUtil.checkForExternalInvocations(Map<String,ServiceDefinition> sdefs,
ActivityUnit actUnit,
MEPDefinition mep,
int from,
int to)
Check if there are any external service invocations during the scope of
the suppled MEP definition.
|
protected static void |
ServiceDefinitionUtil.checkForServiceInvoked(Map<String,ServiceDefinition> sdefs,
ActivityUnit actUnit,
int from,
int to,
InvocationDefinition idef)
This method checks for the events associated with the service
being invoked.
|
static Collection<ServiceDefinition> |
ServiceDefinitionUtil.derive(ActivityUnit actUnit)
This method processes the supplied activity unit to derive
service definition information.
|
protected static MEPDefinition |
ServiceDefinitionUtil.processServiceInvoked(Map<String,ServiceDefinition> sdefs,
ActivityUnit actUnit,
RequestReceived rqr,
ResponseSent rps)
This method processes the service invocation.
|
Modifier and Type | Method and Description |
---|---|
ActivityUnit |
CallTraceServiceImpl.CTState.getActivityUnit(String id)
This method returns the activity unit associated with
the supplied id.
|
Modifier and Type | Method and Description |
---|---|
List<ActivityUnit> |
CallTraceServiceImpl.CTState.getActivityUnits()
This method returns the list of activity units.
|
List<ActivityUnit> |
CallTraceServiceImpl.CTState.getActivityUnits(Context context)
This method returns the list of activity units containing
the specified context.
|
protected static List<ActivityUnit> |
CallTraceServiceImpl.getTopLevelAUs(CallTraceServiceImpl.CTState state)
This method identifies the top level activity units that
contain receive request activities, with no corresponding
send request.
|
Modifier and Type | Method and Description |
---|---|
void |
CallTraceServiceImpl.CTState.add(ActivityUnit au)
This method adds the supplied activity unit to the
state information.
|
protected static void |
CallTraceServiceImpl.checkForLinkedAU(ActivityType cur,
CallTraceServiceImpl.CTState state,
ActivityUnit au,
List<ActivityUnit> topLevel)
This method checks whether there is a linked context.
|
CallTraceServiceImpl.ActivityUnitCursor |
CallTraceServiceImpl.CTState.getCursor(ActivityUnit au)
This method returns the cursor associated with the
supplied activity unit.
|
protected static void |
CallTraceServiceImpl.instrumentCall(Call call,
ActivityUnit au,
RPCActivityType at)
This method adds client or server specific information to the call,
depending upon whether the activity is the client sending or server
receiving the interaction.
|
protected static void |
CallTraceServiceImpl.processAU(CallTraceServiceImpl.CTState state,
ActivityUnit startau,
List<ActivityUnit> topLevel)
This method processes the supplied activity unit to
create a set of trace nodes.
|
protected static boolean |
CallTraceServiceImpl.processSubsequentAU(ActivityUnit previous,
ActivityUnit subsequent)
This method determines whether the subsequent activity unit should be processed
following the previous activity unit.
|
protected static boolean |
CallTraceServiceImpl.shouldPostpone(CallTraceServiceImpl.CTState state,
ActivityUnit au,
List<ActivityUnit> topLevel,
ActivityType cur)
This method identifies whether processing should be postponed
based on the current activity type.
|
Modifier and Type | Method and Description |
---|---|
protected static void |
CallTraceServiceImpl.checkForLinkedAU(ActivityType cur,
CallTraceServiceImpl.CTState state,
ActivityUnit au,
List<ActivityUnit> topLevel)
This method checks whether there is a linked context.
|
protected static void |
CallTraceServiceImpl.processAU(CallTraceServiceImpl.CTState state,
ActivityUnit startau,
List<ActivityUnit> topLevel)
This method processes the supplied activity unit to
create a set of trace nodes.
|
protected static boolean |
CallTraceServiceImpl.shouldPostpone(CallTraceServiceImpl.CTState state,
ActivityUnit au,
List<ActivityUnit> topLevel,
ActivityType cur)
This method identifies whether processing should be postponed
based on the current activity type.
|
Constructor and Description |
---|
CallTraceServiceImpl.ActivityUnitCursor(ActivityUnit unit)
This is the constructor for the cursor.
|
Copyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.