- swipl
- library
- error.pl -- Error generating support
- apply.pl -- Apply predicates on a list
- lists.pl -- List Manipulation
- debug.pl -- Print debug messages and test assertions
- broadcast.pl -- Event service
- socket.pl -- Network socket (TCP and UDP) library
- predicate_options.pl -- Access and analyse predicate options
- shlib.pl -- Utility library for loading foreign objects (DLLs, shared objects)
- option.pl -- Option list processing
- uid.pl -- User and group management on Unix systems
- unix.pl -- Unix specific operations
- syslog.pl -- Unix syslog interface
- thread_pool.pl -- Resource bounded thread management
- gensym.pl -- Generate unique symbols
- settings.pl -- Setting management
- arithmetic.pl -- Extensible arithmetic
- main.pl -- Provide entry point for scripts
- readutil.pl -- Read utilities
- ssl.pl -- Secure Socket Layer (SSL) library
- crypto.pl -- Cryptography and authentication library
- filesex.pl -- Extended operations on files
- doc_http.pl -- Documentation server
- pldoc.pl -- Process source documentation
- operators.pl -- Manage operators
- pairs.pl -- Operations on key-value lists
- prolog_source.pl -- Examine Prolog source-files
- sgml.pl -- SGML, XML and HTML parser
- quasi_quotations.pl -- Define Quasi Quotation syntax
- uri.pl -- Process URIs
- url.pl -- Analysing and constructing URL
- www_browser.pl -- Open a URL in the users browser
- prolog_colour.pl -- Prolog syntax colouring support.
- record.pl -- Access compound arguments by name
- prolog_xref.pl -- Prolog cross-referencer data collection
- occurs.pl -- Finding and counting sub-terms
- ordsets.pl -- Ordered set manipulation
- assoc.pl -- Binary associations
- ugraphs.pl -- Graph manipulation library
- memfile.pl
- xpath.pl -- Select nodes in an XML DOM
- iostream.pl -- Utilities to deal with streams
- atom.pl -- Operations on atoms
- porter_stem.pl
- solution_sequences.pl -- Modify solution sequences
- prolog_pack.pl -- A package manager for Prolog
- prolog_config.pl -- Provide configuration information
- process.pl -- Create processes and redirect I/O
- git.pl -- Run GIT commands
- ctypes.pl -- Character code classification
- time.pl -- Time and alarm library
- utf8.pl -- UTF-8 encoding/decoding on lists of character codes.
- base64.pl -- Base64 encoding and decoding
- sha.pl -- SHA secure hashes
- crypt.pl
- persistency.pl -- Provide persistent dynamic predicates
- pure_input.pl -- Pure Input from files and streams
- nb_set.pl -- Non-backtrackable sets
- xsdp_types.pl -- XML-Schema primitive types
- uuid.pl -- Universally Unique Identifier (UUID) Library
- pcre.pl -- Perl compatible regular expression matching for SWI-Prolog
- aggregate.pl -- Aggregation operators on backtrackable predicates
- rdf_write.pl -- Write RDF/XML from a list of triples
- rdf.pl -- RDF/XML parser
- sgml_write.pl -- XML/SGML writer module
- archive.pl -- Access several archive formats
- csv.pl -- Process CSV (Comma-Separated Values) data
- dialect.pl -- Support multiple Prolog dialects
- apply_macros.pl -- Goal expansion rules to avoid meta-calling
- prolog_code.pl -- Utilities for reasoning about code
- prolog_stack.pl -- Examine the Prolog stack
- pengines.pl -- Pengines: Web Logic Programming Made Easy
- yall.pl -- Lambda expressions
- random.pl -- Random numbers
- zlib.pl -- Zlib wrapper for SWI-Prolog
- bdb.pl -- Berkeley DB interface
- hash_stream.pl -- Maintain a hash on a stream
- md5.pl -- MD5 hashes
- sandbox.pl -- Sandboxed Prolog code
- prolog_format.pl -- Analyse format specifications
- pprint.pl -- Pretty Print Prolog terms
- lazy_lists.pl -- Lazy list handling
- helpidx.pl
- pengines_io.pl -- Provide Prolog I/O for HTML clients
- edinburgh.pl -- Some traditional Edinburgh predicates
- prolog_clause.pl -- Get detailed source-information about a clause
- prolog_breakpoints.pl -- Manage Prolog break-points
- dicts.pl -- Dict utilities
- dif.pl -- The dif/2 constraint
- thread.pl -- High level thread primitives
- system.pl -- System utilities
- modules.pl -- Module utility predicates
- rbtrees.pl -- Red black trees
- listing.pl -- List programs and pretty print clauses
- optparse.pl -- command line parsing
- strings.pl -- String utilities
- double_metaphone.pl -- Phonetic string matching
- intercept.pl -- Intercept and signal interface
- table.pl
- backcomp.pl -- Backward compatibility
- quintus.pl -- Quintus compatibility
- prolog_debug.pl -- User level debugging tools
- make.pl -- Reload modified source files
- redis.pl -- Redis client
- help.pl -- Text based manual
- c14n2.pl -- C14n2 canonical XML documents
- xmldsig.pl -- XML Digital signature
- xmlenc.pl -- XML encryption library
- files.pl
- redis_streams.pl -- Using Redis streams
- prolog_stream.pl -- A stream with Prolog callbacks
- tty.pl -- Terminal operations
- snowball.pl -- The Snowball multi-lingual stemmer library
- sort.pl
- varnumbers.pl -- Utilities for numbered terms
- portray_text.pl -- Portray text
- heaps.pl -- heaps/priority queues
- terms.pl -- Term manipulation
- when.pl -- Conditional coroutining
- zip.pl -- Access resource ZIP archives
- charsio.pl -- I/O on Lists of Character Codes
- wfs.pl -- Well Founded Semantics interface
- protobufs.pl -- Google's Protocol Buffers ("protobufs")
- edit.pl -- Editor interface
- streampool.pl -- Input multiplexing
- fastrw.pl -- Fast reading and writing of terms
- tables.pl -- XSB interface to tables
- ansi_term.pl -- Print decorated text to ANSI consoles
- test_cover.pl -- Clause coverage analysis
- shell.pl -- Elementary shell commands
- explain.pl -- Describe Prolog Terms
- term_to_json.pl
- language_server.pl
- cgi.pl -- Read CGI parameters
- readline.pl -- GNU readline interface
- statistics.pl -- Get information about resource usage
- streams.pl -- Manage Prolog streams
- plunit.pl -- Unit Testing
- paxos.pl -- A Replicated Data Store
- udp_broadcast.pl -- A UDP broadcast proxy
- doc_latex.pl -- PlDoc LaTeX backend
- threadutil.pl -- Interactive thread utilities
- editline.pl -- BSD libedit based command line editing
- base32.pl -- Base32 encoding and decoding
- codesio.pl -- I/O on Lists of Character Codes
- coinduction.pl -- Co-Logic Programming
- date.pl -- Process dates and times
- unicode.pl -- Unicode string handling
- yaml.pl -- Process YAML data
- check.pl -- Consistency checking
- prolog_codewalk.pl -- Prolog code walker
- prolog_autoload.pl -- Autoload all dependencies
- isub.pl -- isub: a string similarity measure
- prolog_wrap.pl -- Wrapping predicates
- prolog_trace.pl -- Print access to predicates
- qsave.pl -- Save current program as a state or executable
- prolog_metainference.pl -- Infer meta-predicate properties
- prolog_history.pl -- Per-directory persistent commandline history
- writef.pl -- Old-style formatted write
- mqi.pl
- rewrite_term.pl
- odbc.pl
- prolog_jiti.pl -- Just In Time Indexing (JITI) utilities
- rlimit.pl
- rdf_triple.pl -- Create triples from intermediate representation
- rdf_parser.pl
- hashtable.pl -- Hash tables
- stomp.pl -- STOMP client.
- stomp_connection/5
- stomp_connection/6
- stomp_connection_property/2
- stomp_destroy_connection/1
- stomp_setup/2
- stomp_teardown/1
- stomp_reconnect/1
- stomp_connect/1
- stomp_connect/2
- stomp_send/4
- stomp_send_json/4
- stomp_subscribe/4
- stomp_unsubscribe/2
- stomp_ack/3
- stomp_nack/3
- stomp_ack/2
- stomp_nack/2
- stomp_begin/2
- stomp_commit/2
- stomp_abort/2
- stomp_transaction/2
- stomp_disconnect/2
- increval.pl -- Incremental dynamic predicate modification
- pwp.pl -- Prolog Well-formed Pages
- doc_files.pl -- Create stand-alone documentation files
- oset.pl -- Ordered set manipulation
- library
- stomp_connection(+Address, +Host, +Headers, :Callback, -Connection) is det
- stomp_connection(+Address, +Host, +Headers, :Callback, -Connection, +Options) is det
- Create a connection reference. The connection is not set up yet by
this predicate. Callback is called on any received frame except for
heart beat frames as below.
call(Callback, Command, Connection, Header, Body)
Where command is one of the commands below. Header is a dict holding the STOMP frame header, where all values are strings except for the
'content-length'
key value which is passed as an integer.Body is a string or, if the data is of the type
application/json
, a dict.- connected
- A connection was established. Connection and Header are valid.
- disconnected
- The connection was lost. Only Connection is valid.
- message
- A message arrived. All three arguments are valid. Body is
a dict if the
content-type
of the message isapplication/json
and a string otherwise. - heartbeat
- A heartbeat was received. Only Connection is valid. This callback is also called for each newline that follows a frame. These newlines can be a heartbeat, but can also be additional newlines that follow a frame.
- heartbeat_timeout
- No heartbeat was received. Only Connection is valid.
- error
- An error happened. All three arguments are valid and handled
as
message
.
Note that stomp_teardown/1 causes the receiving and heartbeat thread to be signalled with abort/0.
Options processed:
- reconnect(+Bool)
- Try to reestablish the connection to the server if the
connection is lost. Default is
false
- connect_timeout(+Seconds)
- Maximum time to try and reestablish a connection. The
default is
600
(10 minutes). - json_options(+Options)
- Options passed to json_read_dict/3 to translate
application/json
content to Prolog. Default is[]
.
- Arguments:
-
Address - is a valid address for tcp_connect/3. Normally a term Host:Port, e.g., localhost:32772
.Host - is a path denoting the STOMP host. Often just /
.Headers - is a dict with STOMP headers used for the CONNECT
request.Connection - is an opaque ground term that identifies the connection.