Add avis 1.2.0, elvin Publish/Subscribe Message Bus server based on the

Elvin protocol.

PR:		ports/120111
Submitted by:	Benjamin Close <benjsc at FreeBSD.org>
This commit is contained in:
Vanilla I. Shu
2008-01-29 14:43:28 +00:00
parent 680946be82
commit 3ebbb6fe4e
9 changed files with 160 additions and 0 deletions

34
java/avis/files/avisd.sh Normal file
View File

@@ -0,0 +1,34 @@
#!/bin/sh
#
# $FreeBSD$
#
# PROVIDE: avisd
# REQUIRE: LOGIN
# KEYWORD: shutdown
# Add the following line to /etc/rc.conf to enable `avisd':
#
#avisd_enable="YES"
#
# See avisd(1) for avisd_flags
#
. "/etc/rc.subr"
name="avisd"
rcvar=`set_rcvar`
logfile="/var/log/avis.log"
command="/usr/local/sbin/avisd"
pidfile="/var/run/$name.pid"
command_args="-c /usr/local/etc/$name.conf -daemon -pidfile $pidfile -logfile $logfile"
command_interpreter=/bin/sh
required_files="/usr/local/etc/$name.conf"
# read configuration and set defaults
load_rc_config "$name"
: ${avisd_enable="NO"}
: ${avisd_flags=""}
run_rc_command "$1"

View File

@@ -0,0 +1,11 @@
--- server/bin/avisd 2008-01-19 19:22:26.000000000 +1030
+++ server/bin/avisd.new 2008-01-29 16:40:15.038606540 +1030
@@ -51,7 +51,7 @@
command="java $java_options -jar $avisd_jar $avis_opts"
-if [ $daemon == 1 ]; then
+if [ $daemon -eq 1 ]; then
if [ -z $logfile ]; then
logfile=/dev/null

View File

@@ -0,0 +1,11 @@
--- server/build.xml-orig 2008-01-29 17:22:51.909302396 +1030
+++ server/build.xml 2008-01-29 17:22:36.780316170 +1030
@@ -22,7 +22,7 @@
<property name="server" value="${basedir}" />
- <property name="common" value="${server}/../common" />
+ <property name="common" value="${server}/../common/java" />
<property name="client" value="${server}/../client" />
<property name="avis-root" value="${server}/../.." />

View File

@@ -0,0 +1,17 @@
--- server/src/main/org/avis/federation/Link.java-orig 2008-01-21 18:05:26.000000000 +1030
+++ server/src/main/org/avis/federation/Link.java 2008-01-29 17:16:37.334636622 +1030
@@ -302,7 +285,7 @@
private void handleAck (Ack ack)
{
- if (ack.request instanceof FedSubReplace)
+ if (ack.request.getClass () == FedSubReplace.class)
subscribed = true;
}
@@ -409,3 +392,5 @@
return newRouting;
}
}
+
+