class StreamUnsubscriber implements Unsubscriber {

    @Override
    public void unsubscribe(SubscriptionContext context)
    {
        WPSRequest request = new WPSRequest();
        request.setIdentifier(StreamingConstants.UNSUBSCRIBE_PROCESS);
        request.setRawDataOutput(StreamingConstants.UNSUBSCRIBE_OUTPUT);

        List<HashMapEntryType> dataInputs = New.list();

        HashMapEntryType filterId = new HashMapEntryType();
        filterId.setKey(context.getFilterIdParameterName());
        filterId.setValue(context.getStreamId().toString());
        dataInputs.add(filterId);

        request.setDataInput(dataInputs);

        myRequestExecuter.execute(request);
    }

    public  StreamUnsubscriber(WPSRequestExecuter envoy);

}