Sha256: 13ab6ef01e3131b3089e6a2796a68425033e323c259593e550494952cb8efe5e
Contents?: true
Size: 1.29 KB
Versions: 14
Compression:
Stored size: 1.29 KB
Contents
module MCollective
# Connector plugins handle the communications with the middleware, you can provide your own to speak
# to something other than Stomp, your plugins must inherit from MCollective::Connector::Base and should
# provide the following methods:
#
# connect - Creates a connection to the middleware, no arguments should get its parameters from the config
# receive - Receive data from the middleware, should act like a blocking call only returning if/when data
# was received. It should get data from all subscribed channels/topics. Individual messages
# should be returned as MCollective::Request objects with the payload provided
# publish - Takes a target and msg, should send the message to the supplied target topic or destination
# subscribe - Adds a subscription to a specific message source
# unsubscribe - Removes a subscription to a specific message source
# disconnect - Disconnects from the middleware
#
# These methods are all that's needed for a new connector protocol and should hopefully be simple
# enough to not have tied us to Stomp.
module Connector
class Base
def self.inherited(klass)
PluginManager << {:type => "connector_plugin", :class => klass.to_s}
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems