Package | Description |
---|---|
io.fabric8.gateway.handlers.detecting.protocol.openwire.command |
Command objects used via the Command Pattern to communicate among nodes
|
io.fabric8.gateway.handlers.detecting.protocol.openwire.support.blob |
Helper classes for dealing with out-of-band BLOB objects
|
Modifier and Type | Method and Description |
---|---|
protected void |
ActiveMQMessage.checkReadOnlyBody() |
protected void |
ActiveMQMessage.checkValidObject(Object value) |
protected void |
ActiveMQStreamMessage.checkWriteOnlyBody() |
protected void |
ActiveMQBytesMessage.checkWriteOnlyBody() |
void |
ActiveMQStreamMessage.clearBody() |
abstract void |
Message.clearBody() |
void |
ActiveMQTextMessage.clearBody() |
void |
ActiveMQObjectMessage.clearBody() |
void |
ActiveMQBytesMessage.clearBody() |
void |
ActiveMQMessage.clearBody() |
void |
ActiveMQMapMessage.clearBody() |
long |
ActiveMQBytesMessage.getBodyLength() |
boolean |
ActiveMQMapMessage.getBoolean(String name) |
boolean |
ActiveMQMessage.getBooleanProperty(String name) |
byte |
ActiveMQMapMessage.getByte(String name) |
byte |
ActiveMQMessage.getByteProperty(String name) |
byte[] |
ActiveMQMapMessage.getBytes(String name) |
char |
ActiveMQMapMessage.getChar(String name) |
Map<String,Object> |
ActiveMQMapMessage.getContentMap() |
double |
ActiveMQMapMessage.getDouble(String name) |
double |
ActiveMQMessage.getDoubleProperty(String name) |
float |
ActiveMQMapMessage.getFloat(String name) |
float |
ActiveMQMessage.getFloatProperty(String name) |
InputStream |
ActiveMQBlobMessage.getInputStream() |
int |
ActiveMQMapMessage.getInt(String name) |
int |
ActiveMQMessage.getIntProperty(String name) |
long |
ActiveMQMapMessage.getLong(String name) |
long |
ActiveMQMessage.getLongProperty(String name) |
Enumeration<String> |
ActiveMQMapMessage.getMapNames() |
Serializable |
ActiveMQObjectMessage.getObject()
Gets the serializable object containing this message's data.
|
Object |
ActiveMQMapMessage.getObject(String name) |
Object |
ActiveMQMessage.getObjectProperty(String name) |
Enumeration |
ActiveMQMessage.getPropertyNames() |
short |
ActiveMQMapMessage.getShort(String name) |
short |
ActiveMQMessage.getShortProperty(String name) |
String |
ActiveMQMapMessage.getString(String name) |
String |
ActiveMQMessage.getStringProperty(String name) |
String |
ActiveMQTextMessage.getText() |
URL |
ActiveMQBlobMessage.getURL() |
boolean |
ActiveMQMapMessage.itemExists(String name) |
void |
ActiveMQStreamMessage.onSend() |
void |
ActiveMQBlobMessage.onSend() |
void |
ActiveMQBytesMessage.onSend() |
void |
ActiveMQMessage.onSend()
Send operation event listener.
|
boolean |
ActiveMQMessage.propertyExists(String name) |
protected void |
ActiveMQMapMessage.put(String name,
Object value) |
boolean |
ActiveMQStreamMessage.readBoolean() |
boolean |
ActiveMQBytesMessage.readBoolean() |
byte |
ActiveMQStreamMessage.readByte() |
byte |
ActiveMQBytesMessage.readByte() |
int |
ActiveMQStreamMessage.readBytes(byte[] value) |
int |
ActiveMQBytesMessage.readBytes(byte[] value) |
int |
ActiveMQBytesMessage.readBytes(byte[] value,
int length) |
char |
ActiveMQStreamMessage.readChar() |
char |
ActiveMQBytesMessage.readChar() |
double |
ActiveMQStreamMessage.readDouble() |
double |
ActiveMQBytesMessage.readDouble() |
float |
ActiveMQStreamMessage.readFloat() |
float |
ActiveMQBytesMessage.readFloat() |
int |
ActiveMQStreamMessage.readInt() |
int |
ActiveMQBytesMessage.readInt() |
long |
ActiveMQStreamMessage.readLong() |
long |
ActiveMQBytesMessage.readLong() |
Object |
ActiveMQStreamMessage.readObject() |
short |
ActiveMQStreamMessage.readShort() |
short |
ActiveMQBytesMessage.readShort() |
String |
ActiveMQStreamMessage.readString() |
int |
ActiveMQBytesMessage.readUnsignedByte() |
int |
ActiveMQBytesMessage.readUnsignedShort() |
String |
ActiveMQBytesMessage.readUTF() |
void |
ActiveMQStreamMessage.reset() |
void |
ActiveMQBytesMessage.reset() |
void |
ActiveMQMapMessage.setBoolean(String name,
boolean value) |
void |
ActiveMQMessage.setBooleanProperty(String name,
boolean value) |
void |
ActiveMQMessage.setBooleanProperty(String name,
boolean value,
boolean checkReadOnly) |
void |
ActiveMQMapMessage.setByte(String name,
byte value) |
void |
ActiveMQMessage.setByteProperty(String name,
byte value) |
void |
ActiveMQMapMessage.setBytes(String name,
byte[] value) |
void |
ActiveMQMapMessage.setBytes(String name,
byte[] value,
int offset,
int length) |
void |
ActiveMQMapMessage.setChar(String name,
char value) |
void |
ActiveMQMapMessage.setDouble(String name,
double value) |
void |
ActiveMQMessage.setDoubleProperty(String name,
double value) |
void |
ActiveMQMapMessage.setFloat(String name,
float value) |
void |
ActiveMQMessage.setFloatProperty(String name,
float value) |
void |
ActiveMQMapMessage.setInt(String name,
int value) |
void |
ActiveMQMessage.setIntProperty(String name,
int value) |
void |
ActiveMQMapMessage.setLong(String name,
long value) |
void |
ActiveMQMessage.setLongProperty(String name,
long value) |
void |
ActiveMQObjectMessage.setObject(Serializable newObject) |
void |
ActiveMQMapMessage.setObject(String name,
Object value) |
void |
ActiveMQBytesMessage.setObjectProperty(String name,
Object value) |
void |
ActiveMQMessage.setObjectProperty(String name,
Object value) |
void |
ActiveMQMessage.setObjectProperty(String name,
Object value,
boolean checkReadOnly) |
void |
ActiveMQMapMessage.setShort(String name,
short value) |
void |
ActiveMQMessage.setShortProperty(String name,
short value) |
void |
ActiveMQMapMessage.setString(String name,
String value) |
void |
ActiveMQMessage.setStringProperty(String name,
String value) |
void |
ActiveMQTextMessage.setText(String text) |
void |
ActiveMQStreamMessage.writeBoolean(boolean value) |
void |
ActiveMQBytesMessage.writeBoolean(boolean value) |
void |
ActiveMQStreamMessage.writeByte(byte value) |
void |
ActiveMQBytesMessage.writeByte(byte value) |
void |
ActiveMQStreamMessage.writeBytes(byte[] value) |
void |
ActiveMQBytesMessage.writeBytes(byte[] value) |
void |
ActiveMQStreamMessage.writeBytes(byte[] value,
int offset,
int length) |
void |
ActiveMQBytesMessage.writeBytes(byte[] value,
int offset,
int length) |
void |
ActiveMQStreamMessage.writeChar(char value) |
void |
ActiveMQBytesMessage.writeChar(char value) |
void |
ActiveMQStreamMessage.writeDouble(double value) |
void |
ActiveMQBytesMessage.writeDouble(double value) |
void |
ActiveMQStreamMessage.writeFloat(float value) |
void |
ActiveMQBytesMessage.writeFloat(float value) |
void |
ActiveMQStreamMessage.writeInt(int value) |
void |
ActiveMQBytesMessage.writeInt(int value) |
void |
ActiveMQStreamMessage.writeLong(long value) |
void |
ActiveMQBytesMessage.writeLong(long value) |
void |
ActiveMQStreamMessage.writeObject(Object value) |
void |
ActiveMQBytesMessage.writeObject(Object value) |
void |
ActiveMQStreamMessage.writeShort(short value) |
void |
ActiveMQBytesMessage.writeShort(short value) |
void |
ActiveMQStreamMessage.writeString(String value) |
void |
ActiveMQBytesMessage.writeUTF(String value) |
Modifier and Type | Method and Description |
---|---|
protected URL |
DefaultBlobUploadStrategy.createUploadURL(ActiveMQBlobMessage message) |
void |
DefaultBlobUploadStrategy.deleteFile(ActiveMQBlobMessage message) |
URL |
BlobUploader.upload(ActiveMQBlobMessage message) |
URL |
BlobUploadStrategy.uploadFile(ActiveMQBlobMessage message,
File file) |
URL |
DefaultBlobUploadStrategy.uploadFile(ActiveMQBlobMessage message,
File file) |
URL |
BlobUploadStrategy.uploadStream(ActiveMQBlobMessage message,
InputStream in) |
URL |
DefaultBlobUploadStrategy.uploadStream(ActiveMQBlobMessage message,
InputStream fis) |
Copyright © 2011–2014 Red Hat. All rights reserved.