Experience Delivers

Build brand, drive demand and extend your reach with web experience management

#Polling interval
$interval = 4;

# URL to hit For Replication Queue Status: curl  [http://admin:admin@]:/etc/replication/agents.author/publish.html]
$fwd_target = "/etc/replication/agents.author/publish.html";

# URL to hit For Reverse Replication Queue Status: curl  [http://admin:admin@]:/etc/replication/agents.author/publish_reverse.html]
$rev_target = "/etc/replication/agents.author/publish_reverse.html";

#Host Name or IP and Port of machine running CQ instance.
$host = ":";

#Admin Credentials of CQ Instance
$id = "admin:admin@";

#1st Part of Curl Command. Specify curl parameters here.
$curl = "/usr/bin/curl \-s \-o \-";

#!/usr/bin/perl
#*************************************************************************
# ADOBE SYSTEMS INCORPORATED
# Copyright 2012 Adobe Systems Incorporated
# All Rights Reserved.
# 
# NOTICE:  Adobe permits you to use, modify, and distribute this file in 
# accordance with the terms of the Adobe license agreement accompanying it.  
# If you have received this file from a source other than Adobe, 
# then your use, modification, or distribution of it requires the prior 
# written permission of Adobe.
#*************************************************************************
# URL to hit For Replication Queue Status: curl  http://admin:admin@:/etc/replication/agents.author/publish.html
# URL to hit For Reverse Replication Queue Status: curl  http://admin:admin@:/etc/replication/agents.author/publish_reverse.html
# 
#Data logged:date,time,repstat,repq,rrepstat,rrepq

#Polling interval
$interval = 4;
# URL to hit For Replication Queue Status:http://admin:admin@:/etc/replication/agents.author/publish.html
$fwd_target = "/etc/replication/agents.author/publish.html";
# URL to hit For Reverse Replication Queue Status:http://admin:admin@:/etc/replication/agents.author/publish_reverse.html
$rev_target = "/etc/replication/agents.author/publish_reverse.html";

#Host Name or IP and Port of machine running CQ instance.
$host = ":";

#Admin Credentials of CQ Instance
$id = "admin:admin@";

#1st Part of Curl Command. Specify curl parameters here.
$curl = "/usr/bin/curl -s -o -";



sub scan
{
local $status;

local ( $target ) = @_;

$stream = "$curl http://$id$host$target";

$status = "?,?";

die "can't execute curl operation" unless open DATA, "$stream|";
while () {
#Queue Status can be active/blocked/idle
  if (/\
Queue is active - 90 pending
      #
      if (/cq-agent-queue-active">Queue is active - (\d+) pending/) { $status = "active,$1"; }

      #  
Queue is blocked - 20 pending
      #
      if (/cq-agent-queue-blocked">Queue is blocked - (\d+) pending/) { $status = "blocked,$1"; }

      #  
Queue is idle
      #
      if (/cq-agent-queue-idle">Queue is idle/) { $status = "idle,0"; }

      last;
  }
}
close DATA;

return $status;
}

#Function to get date for time stamp in logs
sub timestamp
{
   local($date);
   local($sec,$min,$hour,$mday,$mon,$year) = localtime;
   $year += 1900;
   $mon += 1;
   $date = sprintf("%04d-%02d-%02d,%02d:%02d:%02d",
                  $year, $mon, $mday, $hour, $min, $sec);
   return $date;
}

#Main function which will poll Publish and Publish_Reverse page in pre-defined interval.
print "# Replication Queue Details From $host\n";
print "date,time,repQueueStatus,repQueueSize,revRepQueueStatus,revRepQueueSize\n";

while (1) {
   #get timestamp
   $ts = ×tamp;
   #get replication queue stats
   $fst = &scan($fwd_target);
   #get reverse replication queue stats
   $rst = &scan($rev_target);
   print "$ts,$fst,$rst\n";
   sleep $interval;
}