A C D E G O P R S U

A

ActivityAggregator - Class in org.apache.streams.messaging.aggregation

ActivityAggregator() - Constructor for class org.apache.streams.messaging.aggregation.ActivityAggregator

ActivityConsumerRouteBuilder - Interface in org.apache.streams.messaging.routers

ActivityConsumerRouter - Class in org.apache.streams.messaging.routers.impl

ActivityConsumerRouter() - Constructor for class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

ActivityPublisherRegistrationProcessor - Class in org.apache.streams.messaging.processors

ActivityPublisherRegistrationProcessor() - Constructor for class org.apache.streams.messaging.processors.ActivityPublisherRegistrationProcessor

ActivityService - Interface in org.apache.streams.messaging.service

ActivityStreamsSubscriberRegistrationProcessor - Class in org.apache.streams.messaging.processors

ActivityStreamsSubscriberRegistrationProcessor(SubscriptionService) - Constructor for class org.apache.streams.messaging.processors.ActivityStreamsSubscriberRegistrationProcessor

ActivityStreamsSubscriberRouteBuilder - Interface in org.apache.streams.messaging.routers

ActivityStreamsSubscriberRouter - Class in org.apache.streams.messaging.routers.impl

ActivityStreamsSubscriberRouter() - Constructor for class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

C

camelContext - Variable in class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

camelContext - Variable in class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

CassandraActivityService - Class in org.apache.streams.messaging.service.impl

CassandraActivityService(CassandraActivityStreamsRepository, ObjectMapper) - Constructor for class org.apache.streams.messaging.service.impl.CassandraActivityService

CassandraSubscriptionService - Class in org.apache.streams.messaging.service.impl

CassandraSubscriptionService(CassandraSubscriptionRepository) - Constructor for class org.apache.streams.messaging.service.impl.CassandraSubscriptionService

configure() - Method in class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

configure() - Method in class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

createNewRouteForConsumer(Exchange, ActivityConsumer) - Method in interface org.apache.streams.messaging.routers.ActivityConsumerRouteBuilder

createNewRouteForConsumer(Exchange, ActivityConsumer) - Method in class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

createNewRouteForSubscriber(Exchange, ActivityStreamsSubscriber) - Method in interface org.apache.streams.messaging.routers.ActivityStreamsSubscriberRouteBuilder

createNewRouteForSubscriber(Exchange, ActivityStreamsSubscriber) - Method in class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

D

distributeToSubscribers() - Method in class org.apache.streams.messaging.aggregation.ActivityAggregator

E

EipConfigurator - Class in org.apache.streams.messaging.configuration

EipConfigurator() - Constructor for class org.apache.streams.messaging.configuration.EipConfigurator

ENDPOINT_PROTOCOL_JETTY - Static variable in class org.apache.streams.messaging.configuration.EipConfigurator

ENDPOINT_PROTOCOL_SERVLET - Static variable in class org.apache.streams.messaging.configuration.EipConfigurator

G

getActivitiesForFilters(List<String>, Date) - Method in interface org.apache.streams.messaging.service.ActivityService

getActivitiesForFilters(List<String>, Date) - Method in class org.apache.streams.messaging.service.impl.CassandraActivityService

getBaseUrlPath() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getConsumerActivityQUri() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getConsumerInRouteHost() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getConsumerInRoutePort() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getConsumerReceiveMethod() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getConsumerSplitMethod() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getFilters(String) - Method in class org.apache.streams.messaging.service.impl.CassandraSubscriptionService

getFilters(String) - Method in interface org.apache.streams.messaging.service.SubscriptionService

getPublisherEndpointProtocol() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getPublisherEndpointUrlResource() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberEndpointProtocol() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberEndpointUrlResource() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberGetMethod() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberInRouteHost() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberInRoutePort() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberPostMethod() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

getSubscriberReceiveMethod() - Method in class org.apache.streams.messaging.configuration.EipConfigurator

O

org.apache.streams.messaging.aggregation - package org.apache.streams.messaging.aggregation

org.apache.streams.messaging.configuration - package org.apache.streams.messaging.configuration

org.apache.streams.messaging.processors - package org.apache.streams.messaging.processors

org.apache.streams.messaging.routers - package org.apache.streams.messaging.routers

org.apache.streams.messaging.routers.impl - package org.apache.streams.messaging.routers.impl

org.apache.streams.messaging.service - package org.apache.streams.messaging.service

org.apache.streams.messaging.service.impl - package org.apache.streams.messaging.service.impl

P

process(Exchange) - Method in class org.apache.streams.messaging.processors.ActivityPublisherRegistrationProcessor

process(Exchange) - Method in class org.apache.streams.messaging.processors.ActivityStreamsSubscriberRegistrationProcessor

R

receiveExchange(Exchange) - Method in interface org.apache.streams.messaging.service.ActivityService

receiveExchange(Exchange) - Method in class org.apache.streams.messaging.service.impl.CassandraActivityService

S

saveFilters(ActivityStreamsSubscription) - Method in class org.apache.streams.messaging.service.impl.CassandraSubscriptionService

saveFilters(ActivityStreamsSubscription) - Method in interface org.apache.streams.messaging.service.SubscriptionService

setActivityConsumerWarehouse(ActivityConsumerWarehouse) - Method in class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

setActivityService(CassandraActivityService) - Method in class org.apache.streams.messaging.aggregation.ActivityAggregator

setActivityStreamsSubscriberWarehouse(ActivityStreamsSubscriberWarehouse) - Method in class org.apache.streams.messaging.aggregation.ActivityAggregator

setActivityStreamsSubscriberWarehouse(ActivityStreamsSubscriberWarehouse) - Method in class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

setBaseUrlPath(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setCamelContext(CamelContext) - Method in class org.apache.streams.messaging.routers.impl.ActivityConsumerRouter

setCamelContext(CamelContext) - Method in class org.apache.streams.messaging.routers.impl.ActivityStreamsSubscriberRouter

setConsumerActivityQUri(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setConsumerInRouteHost(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setConsumerInRoutePort(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setConsumerReceiveMethod(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setConsumerSplitMethod(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setPublisherEndpointProtocol(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setPublisherEndpointUrlResource(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberEndpointProtocol(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberEndpointUrlResource(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberGetMethod(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberInRouteHost(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberInRoutePort(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberPostMethod(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

setSubscriberReceiveMethod(String) - Method in class org.apache.streams.messaging.configuration.EipConfigurator

SubscriptionService - Interface in org.apache.streams.messaging.service

U

updateSubscriber(ActivityStreamsSubscriber) - Method in class org.apache.streams.messaging.aggregation.ActivityAggregator

A C D E G O P R S U