OPSI.Util.MessageBus module¶
This module is part of the desktop management solution opsi (open pc server integration) http://www.opsi.org
Copyright (C) 2011 uib GmbH
All rights reserved.
This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License version 2 as published by the Free Software Foundation.
This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
@copyright: uib GmbH <info@uib.de> @author: Jan Schneider <j.schneider@uib.de> @license: GNU General Public License version 2
-
class
OPSI.Util.MessageBus.MessageBusClient(port=None, autoReconnect=True)¶ Bases:
threading.Thread-
connectionFailed(reason)¶
-
connectionLost(reason)¶
-
connectionMade(connection)¶
-
initialized()¶
-
isInitialized()¶
-
isStopping()¶
-
lineReceived(line)¶
-
notifyObjectCreated(obj)¶
-
notifyObjectDeleted(obj)¶
-
notifyObjectEvent(operation, obj)¶
-
notifyObjectUpdated(obj)¶
-
objectEventReceived(object_type, ident, operation)¶
-
registerForObjectEvents(object_types=[], operations=[])¶
-
run()¶
-
sendLine(line)¶
-
start(startReactor=True)¶
-
stop(stopReactor=True)¶
-
transmitMessages(messages)¶
-
waitInitialized(timeout=0.0)¶
-
-
class
OPSI.Util.MessageBus.MessageBusClientFactory(messageBusClient)¶ Bases:
twisted.internet.protocol.ClientFactory-
clientConnectionFailed(client, reason)¶
-
protocol¶ alias of
MessageBusClientProtocol
-
-
class
OPSI.Util.MessageBus.MessageBusClientProtocol¶ Bases:
twisted.protocols.basic.LineReceiver-
connectionLost(reason)¶
-
connectionMade()¶
-
lineReceived(line)¶
-
-
class
OPSI.Util.MessageBus.MessageBusServer(port=None)¶ Bases:
threading.Thread-
isStopping()¶
-
run()¶
-
start(startReactor=True)¶
-
stop(stopReactor=True)¶
-
-
class
OPSI.Util.MessageBus.MessageBusServerFactory¶ Bases:
twisted.internet.protocol.ServerFactory-
connectionCount()¶
-
connectionLost(client, reason)¶
-
connectionMade(client, readonly=False)¶
-
lineReceived(line)¶
-
protocol¶ alias of
MessageBusServerProtocol
-
sendError(errorMessage, clientId=None)¶
-
sendMessage(message, clientId=None)¶
-
transmitMessages(messages, clientId)¶
-
-
class
OPSI.Util.MessageBus.MessageBusServerProtocol¶ Bases:
twisted.protocols.basic.LineReceiver-
connectionLost(reason)¶
-
connectionMade()¶
-
lineReceived(line)¶
-
-
class
OPSI.Util.MessageBus.MessageBusWebsocketClient(url='https://localhost:4447/omb', autoReconnect=True)¶ Bases:
OPSI.Util.MessageBus.MessageBusClient-
connectionMade(connection)¶
-
isWebsocketHandshakeDone()¶
-
lineReceived(line)¶
-
sendLine(line)¶
-
-
class
OPSI.Util.MessageBus.MessageBusWebsocketClientFactory(messageBusClient)¶ Bases:
OPSI.Util.MessageBus.MessageBusClientFactory-
protocol¶ alias of
MessageBusWebsocketClientProtocol
-
-
class
OPSI.Util.MessageBus.MessageBusWebsocketClientProtocol¶ Bases:
OPSI.Util.MessageBus.MessageBusClientProtocol-
lineReceived(line)¶
-
rawDataReceived(data)¶
-
-
class
OPSI.Util.MessageBus.MessageQueue(transport, size=10, poll=0.3, additionalTransportArgs=[])¶ Bases:
threading.Thread-
add(message)¶
-
run()¶
-
stop()¶
-
-
OPSI.Util.MessageBus.getMessageBusSocket()¶