public class org.apache.activemq.store.ProxyMessageStore extends java.lang.Object implements org.apache.activemq.store.MessageStore
{
final org.apache.activemq.store.MessageStore delegate;
public void <init>(org.apache.activemq.store.MessageStore)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.store.MessageStore;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate> = v;
return;
}
public org.apache.activemq.store.MessageStore getDelegate()
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
return v;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
return;
}
public void addMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void addMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v);
return;
}
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.command.MessageId;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId)>(v);
return v;
}
public void recover(org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void recover(org.apache.activemq.store.MessageRecoveryListener)>(v);
return;
}
public void removeAllMessages(org.apache.activemq.broker.ConnectionContext) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeAllMessages(org.apache.activemq.broker.ConnectionContext)>(v);
return;
}
public void removeMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
return;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void start()>();
return;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void stop()>();
return;
}
public void dispose(org.apache.activemq.broker.ConnectionContext)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void dispose(org.apache.activemq.broker.ConnectionContext)>(v);
return;
}
public org.apache.activemq.command.ActiveMQDestination getDestination()
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.command.ActiveMQDestination getDestination()>();
return v;
}
public void setMemoryUsage(org.apache.activemq.usage.MemoryUsage)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.usage.MemoryUsage;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void setMemoryUsage(org.apache.activemq.usage.MemoryUsage)>(v);
return;
}
public int getMessageCount() throws java.io.IOException
{
int v;
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: int getMessageCount()>();
return v;
}
public long getMessageSize() throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
long v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: long getMessageSize()>();
return v;
}
public void recoverNextMessages(int, org.apache.activemq.store.MessageRecoveryListener) throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
int v;
org.apache.activemq.store.ProxyMessageStore v;
org.apache.activemq.store.MessageRecoveryListener v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: int;
v := @parameter: org.apache.activemq.store.MessageRecoveryListener;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void recoverNextMessages(int,org.apache.activemq.store.MessageRecoveryListener)>(v, v);
return;
}
public void resetBatching()
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void resetBatching()>();
return;
}
public void setBatch(org.apache.activemq.command.MessageId) throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.command.MessageId;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void setBatch(org.apache.activemq.command.MessageId)>(v);
return;
}
public boolean isEmpty() throws java.lang.Exception
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: boolean isEmpty()>();
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddQueueMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v);
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message)>(v, v);
return v;
}
public org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.Message, boolean) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ListenableFuture v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.ListenableFuture asyncAddTopicMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.Message,boolean)>(v, v, v);
return v;
}
public void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessageAck) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void removeAsyncMessage(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessageAck)>(v, v);
return;
}
public void setPrioritizedMessages(boolean)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void setPrioritizedMessages(boolean)>(v);
return;
}
public boolean isPrioritizedMessages()
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.ProxyMessageStore v;
boolean v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: boolean isPrioritizedMessages()>();
return v;
}
public void updateMessage(org.apache.activemq.command.Message) throws java.io.IOException
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.command.Message v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void updateMessage(org.apache.activemq.command.Message)>(v);
return;
}
public void registerIndexListener(org.apache.activemq.store.IndexListener)
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.IndexListener v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v := @parameter: org.apache.activemq.store.IndexListener;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
interfaceinvoke v.<org.apache.activemq.store.MessageStore: void registerIndexListener(org.apache.activemq.store.IndexListener)>(v);
return;
}
public java.lang.String toString()
{
org.apache.activemq.store.MessageStore v;
java.lang.String v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
return v;
}
public org.apache.activemq.store.MessageStoreStatistics getMessageStoreStatistics()
{
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.MessageStoreStatistics v;
org.apache.activemq.store.ProxyMessageStore v;
v := @this: org.apache.activemq.store.ProxyMessageStore;
v = v.<org.apache.activemq.store.ProxyMessageStore: org.apache.activemq.store.MessageStore delegate>;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.MessageStoreStatistics getMessageStoreStatistics()>();
return v;
}
}