basic.IncorrectPiping Class Reference

Pipe processors with non-matching event types. More...

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Pipe processors with non-matching event types.

Doing this in BeepBeep causes a ConnectorException to be thrown. This example shows what happens in that case. The chain of processors in this example can be represented graphically as:

The expected output of this program should look like this:

Exception in thread "main" ca.uqac.lif.cep.Connector$IncompatibleTypesException:
Cannot connect output 0 of ABS to input 0 of ¬: incompatible types
 at ca.uqac.lif.cep.Connector.checkForException(Connector.java:357)
 at ca.uqac.lif.cep.Connector.connect(Connector.java:148)
 at ca.uqac.lif.cep.Connector.connect(Connector.java:279)
 at ca.uqac.lif.cep.Connector.connect(Connector.java:251)
 at basic.IncorrectPiping.main(IncorrectPiping.java:42)

If we refer to the picture, the exception is raised when attempting to connect the output of the first function processor (turquoise, representing a number) to the input of the second function processor (light blue, representing a Boolean).

Author

Sylvain Hallé Easy

Definition at line 54 of file IncorrectPiping.java.

Member Function Documentation

main()

static void basic.IncorrectPiping.main ( String []  args )

static

Create a simple source with a single numerical event

Definition at line 56 of file IncorrectPiping.java.

    {
        /// Create a simple source with a single numerical event 
        QueueSource source = new QueueSource();
        source.setEvents(3);
        
        /* Create a processor that computes the absolute value of a number
         * and connect it to that source. */
        Processor av = new ApplyFunction(Numbers.absoluteValue);
        Connector.connect(source, av);
        
        /* Attempt to connect a processor that computes the negation of a
         * Boolean value to the av processor defined above. This will cause an
         * exception to be thrown: the output type of av is Number, while the
         * input type of neg is Boolean. */
        Processor neg = new ApplyFunction(Booleans.not);
        Connector.connect(av, neg); // Will throw an exception
        
        /* As a result, this line of the program should not be reached, as the
         * execution will stop with the throwing of a ConnectorException on
         * the line above. */
        System.out.println("This line will not be reached");
        ///
    }

---

The documentation for this class was generated from the following file:

• Source/src/basic/IncorrectPiping.java