C#

public class Message
{
    string subject;
    EventQueue queue;
    string data = string.Empty;

    public Message(string s, EventQueue queue)
    {
        this.subject = s;
        this.queue = queue;
    }

    public Send()
    {
        queue.Send(this.subject, this, data);
    }
}

smesser wrote:

I thought that the eventQueue was part of the system object.

smesser wrote:

Each instance of message would have it's own eventqueue that would get
disposed of when the message was disposed of taking with it any subscriptions
that may have been made to it.

smesser wrote:

Simple overview:

1. System object creates messages and manages the global eventqueue
2. System object creates and sends events from plugins via the Message send method.
This way there is one global event queue.
3. Plugin has no concept of event queue nor cares about it.

Leslie Sanford wrote:

I think it's number 2 that's giving me trouble. Let's run through a scenario to see if I understand:

1. The System sends a message to a plugin via the OnMessage method.
2. The plugin does something with the message.
3. The plugin wants to send a message telling the System and any other plugins listening that something has happened.
4. The plugin asks the System for a message object representing a specific message, e.g. "PlayCompleted".
5. The plugin gets the message back from the System and sends it calling the message's Send method.

Is this close?

smesser wrote:

5. Close, the plugin would get a the message from the System/EventQueue and either ignore it,
respond to it by using the system object to create a new message and then sending that new
message. The plugin's OnMessage function would return true if the message was consumed.
You wouldn't resend a message sent via the OnMessage function but create a new one if a
response it warranted.

public bool OnMessage(ISystem system, IMessage message)
{
    // Do something with message.
    if(message...)
    {
    }

    // Send a message to system and other plugins:
    IMessage msg = system.NewMessage("Completed");

    msg.Send();

    return true;    
}

public bool OnMessage(ISystem system, IMessage message)
{
    // Do something with message.
    if(message...)
    {
    }

    // Send a message to system and other plugins:
    system.Send("Completed", this, someData);

    return true;    
}

Leslie Sanford wrote:

One thing you may want to consider is to use the System class as a wrapper around the EventQueue class. So instead of using message objects, a plugin would call a method on the system object itself. So...

Leslie Sanford wrote:

One thing that I think needs clearing up is the event handlers in the plugins. If a plugin sends an event to the other plugins, would you require those events to be handled in the OnMessage method, or would you have other methods for handling events from other plugins?

I'm trying to find out if a plugin distinquishes between events sent from the System and from other plugins.

smesser wrote:

The only problem for me with this approach is that my message object inherits from a Data item and also can cantain a list of this data items. It is very flexible and can be used to send lists of any type of data.

public bool OnMessage(ISystem system, IMessage message)
{    
    // Do something with message.    
    if(message...)    
    {    
    }    

    // Send a message to system and other plugins:    
    system.Send("Completed", this, new SomeMessage()); 

    return true;    
}

string s = new string('x', 50000);<br />
string[] a = new string[10000];<br />
for (int i=0; i<10000; i++) a[i] = s;

tasleem143 wrote:

but it gives sql exception i dont know why.what i want to do is create table when app starts on sql server. if you tell me technique of executing sql srcipt file or other method