fix root notifications

diff --git a/sql/londiste/expected/londiste_provider.out b/sql/londiste/expected/londiste_provider.out
index 7829fa7da69333b956c633b5a69131a07cfa03c2..52f12e88a0a0cd3644597cd2c345406418022246 100644 (file)
--- a/sql/londiste/expected/londiste_provider.out
+++ b/sql/londiste/expected/londiste_provider.out
@@ -41,6 +41,7 @@ select * from londiste.node_add_table('aset', 'public.testdata');
       200 | Table added: public.testdata
 (1 row)
 
+insert into testdata (data) values ('test-data');
 select * from londiste.node_get_table_list('aset');
    table_name    | merge_state | custom_snapshot | skip_truncate 
 -----------------+-------------+-----------------+---------------
@@ -64,3 +65,11 @@ select * from londiste.node_get_table_list('aset');
 ------------+-------------+-----------------+---------------
 (0 rows)
 
+select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template;
+ ev_id |   ev_type    |              ev_data               |    ev_extra1    
+-------+--------------+------------------------------------+-----------------
+     1 | add-table    | public.testdata                    | 
+     2 | I            | (id,data) values ('1','test-data') | public.testdata
+     3 | remove-table | public.testdata                    | 
+(3 rows)
+

diff --git a/sql/londiste/functions/londiste.root_notify_change.sql b/sql/londiste/functions/londiste.root_notify_change.sql
index 0f79cc2253be16d3a72a1faa11699df5167a9b42..03183c1641a61b98e191cef8dc27ac3f471564bb 100644 (file)
--- a/sql/londiste/functions/londiste.root_notify_change.sql
+++ b/sql/londiste/functions/londiste.root_notify_change.sql
@@ -20,7 +20,7 @@ begin
         raise exception 'only root node can send events';
     end if;
 
-    perform pgq.insert_event(que, i_ev_data, i_ev_data);
+    perform pgq.insert_event(que, i_ev_type, i_ev_data);
 
     return 1;
 end;

diff --git a/sql/londiste/sql/londiste_provider.sql b/sql/londiste/sql/londiste_provider.sql
index fa17391046f7c564ff96795d4ffd57b3cc40c154..b86223f44a734169f0d8afdc572e0bfba6dfadbd 100644 (file)
--- a/sql/londiste/sql/londiste_provider.sql
+++ b/sql/londiste/sql/londiste_provider.sql
@@ -21,8 +21,11 @@ select * from pgq_set.create_node('aset', 'root', 'rnode', 'londiste_root', null
 
 select * from londiste.node_add_table('aset', 'public.testdata_nopk');
 select * from londiste.node_add_table('aset', 'public.testdata');
+insert into testdata (data) values ('test-data');
 select * from londiste.node_get_table_list('aset');
 select * from londiste.node_remove_table('aset', 'public.testdata');
 select * from londiste.node_remove_table('aset', 'public.testdata');
 select * from londiste.node_get_table_list('aset');
 
+select ev_id, ev_type, ev_data, ev_extra1 from pgq.event_template;
+