PublishBeacon (Java Functional Samples)

Skip navigation links

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- topic.PublishBeacon

```
public class PublishBeacon
extends java.lang.Object
```
Publishes a beacon stream on a topic. A published stream can be subscribed to by other applications. This allows multiple applications to consume tuples from an application. For example an application that ingests & prepares data can be consumed by multiple analytic applications.
Multiple applications (or multiple streams within applications) can publish to the same topic.
Applications dynamically subscribe to a published topic, so that new applications that subscribe to a topic can be submitted at any time.

See Also:

Sample application that subscribes to the topic published by this application, Integration with SPL applications

- Constructor Summary
  
  Constructors
  Constructor and Description
  
  PublishBeacon()
- Method Summary
  
  All Methods Static Methods Concrete Methods
  Modifier and Type Method and Description
  
  static void main(java.lang.String[] args)
  Submit this application which publishes a stream.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - PublishBeacon
```
public PublishBeacon()
```
- Method Detail
  - main
```
public static void main(java.lang.String[] args)
                 throws java.lang.Exception
```
    Submit this application which publishes a stream.
    
    Parameters:
    
    args - Command line arguments, accepts a single optional topic name.
    
    Throws:
    
    java.lang.Exception - Error running the application