Table of Contents - pub_sub_model_sync-1.0.1 Documentation
Pages
Classes and Modules
- Object
- PubSubModelSync
- PubSubModelSync::Base
- PubSubModelSync::Config
- PubSubModelSync::Connector
- PubSubModelSync::Error
- PubSubModelSync::MessageProcessor
- PubSubModelSync::MessagePublisher
- PubSubModelSync::MessagePublisher::MissingPublisher
- PubSubModelSync::MockGoogleService
- PubSubModelSync::MockGoogleService::MockStop
- PubSubModelSync::MockGoogleService::MockSubscriber
- PubSubModelSync::MockGoogleService::MockSubscription
- PubSubModelSync::MockGoogleService::MockTopic
- PubSubModelSync::MockKafkaService
- PubSubModelSync::MockKafkaService::MockConsumer
- PubSubModelSync::MockKafkaService::MockProducer
- PubSubModelSync::MockRabbitService
- PubSubModelSync::MockRabbitService::MockChannel
- PubSubModelSync::MockRabbitService::MockQueue
- PubSubModelSync::MockRabbitService::MockTopic
- PubSubModelSync::PUBLISHER_KLASS
- PubSubModelSync::Payload
- PubSubModelSync::Payload::MissingInfo
- PubSubModelSync::PayloadBuilder
- PubSubModelSync::PublisherConcern
- PubSubModelSync::PublisherConcern::ClassMethods
- PubSubModelSync::Railtie
- PubSubModelSync::RunSubscriber
- PubSubModelSync::Runner
- PubSubModelSync::ServiceBase
- PubSubModelSync::ServiceGoogle
- PubSubModelSync::ServiceKafka
- PubSubModelSync::ServiceRabbit
- PubSubModelSync::Subscriber
- PubSubModelSync::SubscriberConcern
- PubSubModelSync::SubscriberConcern::ClassMethods
- PubSubModelSync::Transaction
Methods
- ::config — PubSubModelSync::Base
- ::connector — PubSubModelSync::MessagePublisher
- ::connector — PubSubModelSync::MessagePublisher
- ::connector_publish — PubSubModelSync::MessagePublisher
- ::connector_publish — PubSubModelSync::MessagePublisher
- ::debug? — PubSubModelSync::Base
- ::default_topic_name — PubSubModelSync::Config
- ::default_topic_name_old — PubSubModelSync::Config
- ::define_transaction_key — PubSubModelSync::MessagePublisher
- ::define_transaction_key — PubSubModelSync::MessagePublisher
- ::ensure_model_publish — PubSubModelSync::MessagePublisher
- ::ensure_model_publish — PubSubModelSync::MessagePublisher
- ::ensure_publish — PubSubModelSync::MessagePublisher
- ::ensure_publish — PubSubModelSync::MessagePublisher
- ::from_payload_data — PubSubModelSync::Payload
- ::included — PubSubModelSync::SubscriberConcern
- ::init_transaction — PubSubModelSync::MessagePublisher
- ::init_transaction — PubSubModelSync::MessagePublisher
- ::log — PubSubModelSync::Base
- ::log — PubSubModelSync::Config
- ::new — PubSubModelSync::Connector
- ::new — PubSubModelSync::MessageProcessor
- ::new — PubSubModelSync::Payload
- ::new — PubSubModelSync::PayloadBuilder
- ::new — PubSubModelSync::RunSubscriber
- ::new — PubSubModelSync::Runner
- ::new — PubSubModelSync::ServiceGoogle
- ::new — PubSubModelSync::ServiceKafka
- ::new — PubSubModelSync::ServiceRabbit
- ::new — PubSubModelSync::Subscriber
- ::new — PubSubModelSync::Transaction
- ::notify_error — PubSubModelSync::MessagePublisher
- ::notify_error — PubSubModelSync::MessagePublisher
- ::ordering_key_for — PubSubModelSync::MessagePublisher
- ::ordering_key_for — PubSubModelSync::PayloadBuilder
- ::ordering_key_for — PubSubModelSync::MessagePublisher
- ::parse_mapping_for — PubSubModelSync::PayloadBuilder
- ::preload_listeners — PubSubModelSync::Runner
- ::publish — PubSubModelSync::MessagePublisher
- ::publish — PubSubModelSync::MessagePublisher
- ::publish! — PubSubModelSync::MessagePublisher
- ::publish! — PubSubModelSync::MessagePublisher
- ::publish_data — PubSubModelSync::MessagePublisher
- ::publish_data — PubSubModelSync::MessagePublisher
- ::publish_model — PubSubModelSync::MessagePublisher
- ::publish_model — PubSubModelSync::MessagePublisher
- ::subscription_key — PubSubModelSync::Config
- ::transaction — PubSubModelSync::MessagePublisher
- ::transaction — PubSubModelSync::MessagePublisher
- #action — PubSubModelSync::Payload
- #add_payload — PubSubModelSync::Transaction
- #add_ps_subscriber — PubSubModelSync::SubscriberConcern::ClassMethods
- #add_transaction — PubSubModelSync::Transaction
- #async_producer — PubSubModelSync::MockKafkaService
- #bind — PubSubModelSync::MockRabbitService::MockQueue
- #build_headers — PubSubModelSync::Payload
- #build_service — PubSubModelSync::Connector
- #call — PubSubModelSync::PayloadBuilder
- #call — PubSubModelSync::RunSubscriber
- #call_action — PubSubModelSync::RunSubscriber
- #call_action_method — PubSubModelSync::RunSubscriber
- #call_before_commit_records — Object
- #channel — PubSubModelSync::MockRabbitService
- #clean_publisher — PubSubModelSync::Transaction
- #close — PubSubModelSync::MockKafkaService
- #close — PubSubModelSync::MockRabbitService
- #close — PubSubModelSync::MockRabbitService::MockChannel
- #commit — Object
- #compute_value — PubSubModelSync::PayloadBuilder
- #consumer — PubSubModelSync::MockKafkaService
- #create_channel — PubSubModelSync::MockRabbitService
- #create_topic — PubSubModelSync::MockGoogleService
- #create_topic — PubSubModelSync::MockKafkaService
- #decode_payload — PubSubModelSync::ServiceBase
- #deliver_all — PubSubModelSync::Transaction
- #deliver_data — PubSubModelSync::ServiceRabbit
- #deliver_messages — PubSubModelSync::MockKafkaService::MockProducer
- #deliver_payloads — PubSubModelSync::Transaction
- #each_message — PubSubModelSync::MockKafkaService::MockConsumer
- #enable_message_ordering! — PubSubModelSync::MockGoogleService::MockTopic
- #encode_payload — PubSubModelSync::ServiceBase
- #ensure_sync — PubSubModelSync::RunSubscriber
- #ensure_topics — PubSubModelSync::ServiceKafka
- #fanout — PubSubModelSync::MockRabbitService::MockChannel
- #filter_subscribers — PubSubModelSync::MessageProcessor
- #find_model — PubSubModelSync::RunSubscriber
- #find_topic — PubSubModelSync::ServiceGoogle
- #finish — PubSubModelSync::Transaction
- #headers_data — PubSubModelSync::PayloadBuilder
- #init_topic — PubSubModelSync::ServiceGoogle
- #klass — PubSubModelSync::Payload
- #klass_subscription? — PubSubModelSync::RunSubscriber
- #listen — PubSubModelSync::MockGoogleService::MockSubscription
- #listen_messages — PubSubModelSync::ServiceBase
- #listen_messages — PubSubModelSync::ServiceGoogle
- #listen_messages — PubSubModelSync::ServiceKafka
- #listen_messages — PubSubModelSync::ServiceRabbit
- #lost_db_connection? — PubSubModelSync::MessageProcessor
- #mark_message_as_processed — PubSubModelSync::MockKafkaService::MockConsumer
- #message_headers — PubSubModelSync::ServiceGoogle
- #message_settings — PubSubModelSync::ServiceKafka
- #message_settings — PubSubModelSync::ServiceRabbit
- #mode — PubSubModelSync::Payload
- #model_identifiers — PubSubModelSync::RunSubscriber
- #name — PubSubModelSync::MockGoogleService::MockTopic
- #name — PubSubModelSync::MockRabbitService::MockQueue
- #notify_error — PubSubModelSync::MessageProcessor
- #parse_condition — PubSubModelSync::RunSubscriber
- #parse_mapping — PubSubModelSync::RunSubscriber
- #populate_model — PubSubModelSync::RunSubscriber
- #process — PubSubModelSync::MessageProcessor
- #process — PubSubModelSync::Payload
- #process! — PubSubModelSync::MessageProcessor
- #process! — PubSubModelSync::Payload
- #process_message — PubSubModelSync::ServiceBase
- #process_message — PubSubModelSync::ServiceGoogle
- #process_message — PubSubModelSync::ServiceKafka
- #process_message — PubSubModelSync::ServiceRabbit
- #processable? — PubSubModelSync::MessageProcessor
- #produce — PubSubModelSync::MockKafkaService::MockProducer
- #producer — PubSubModelSync::MockKafkaService
- #producer — PubSubModelSync::ServiceKafka
- #ps_after_action — PubSubModelSync::PublisherConcern::ClassMethods
- #ps_after_publish — PubSubModelSync::PublisherConcern
- #ps_after_sync — PubSubModelSync::PublisherConcern
- #ps_before_publish — PubSubModelSync::PublisherConcern
- #ps_before_sync — PubSubModelSync::PublisherConcern
- #ps_cache_publish_callbacks — PubSubModelSync::PublisherConcern::ClassMethods
- #ps_class_publish — PubSubModelSync::PublisherConcern::ClassMethods
- #ps_class_subscribe — PubSubModelSync::SubscriberConcern::ClassMethods
- #ps_define_commit_action — PubSubModelSync::PublisherConcern::ClassMethods
- #ps_init_transaction_callbacks — PubSubModelSync::PublisherConcern::ClassMethods
- #ps_perform_publish — PubSubModelSync::PublisherConcern
- #ps_publish — PubSubModelSync::PublisherConcern
- #ps_subscribe — PubSubModelSync::SubscriberConcern::ClassMethods
- #publish — PubSubModelSync::MockGoogleService::MockTopic
- #publish — PubSubModelSync::MockRabbitService::MockTopic
- #publish — PubSubModelSync::MockRabbitService::MockQueue
- #publish — PubSubModelSync::Payload
- #publish — PubSubModelSync::ServiceBase
- #publish — PubSubModelSync::ServiceGoogle
- #publish — PubSubModelSync::ServiceKafka
- #publish — PubSubModelSync::ServiceRabbit
- #publish! — PubSubModelSync::Payload
- #publish_async — PubSubModelSync::MockGoogleService::MockTopic
- #queue — PubSubModelSync::MockRabbitService::MockChannel
- #retry_process? — PubSubModelSync::MessageProcessor
- #rollback — PubSubModelSync::Transaction
- #run — PubSubModelSync::Runner
- #run_class_message — PubSubModelSync::RunSubscriber
- #run_model_message — PubSubModelSync::RunSubscriber
- #run_subscriber — PubSubModelSync::MessageProcessor
- #same_app_message? — PubSubModelSync::ServiceBase
- #settings_data — PubSubModelSync::PayloadBuilder
- #shutdown — PubSubModelSync::MockKafkaService::MockProducer
- #start — PubSubModelSync::MockGoogleService::MockSubscriber
- #start — PubSubModelSync::MockRabbitService
- #start_consumer — PubSubModelSync::ServiceKafka
- #start_listeners — PubSubModelSync::Runner
- #stop — PubSubModelSync::MockGoogleService::MockSubscriber
- #stop — PubSubModelSync::MockKafkaService::MockConsumer
- #stop — PubSubModelSync::ServiceBase
- #stop — PubSubModelSync::ServiceGoogle
- #stop — PubSubModelSync::ServiceKafka
- #stop — PubSubModelSync::ServiceRabbit
- #stop! — PubSubModelSync::MockGoogleService::MockSubscriber
- #subscribe — PubSubModelSync::MockGoogleService::MockTopic
- #subscribe — PubSubModelSync::MockKafkaService::MockConsumer
- #subscribe — PubSubModelSync::MockRabbitService::MockQueue
- #subscribe_to_exchange — PubSubModelSync::ServiceRabbit
- #subscribe_to_queues — PubSubModelSync::ServiceRabbit
- #subscribe_to_topics — PubSubModelSync::ServiceGoogle
- #subscription — PubSubModelSync::MockGoogleService::MockTopic
- #to_h — PubSubModelSync::Payload
- #topic — PubSubModelSync::MockGoogleService
- #topic — PubSubModelSync::MockRabbitService::MockChannel
- #topics — PubSubModelSync::MockKafkaService
- #trap_signals! — PubSubModelSync::Runner
- #validate! — PubSubModelSync::Payload
- #wait! — PubSubModelSync::MockGoogleService::MockStop